class

ActionController::Live::Stream

Inherits Reference < Object

Порт Live::Buffer: буфер с backpressure поверх SizedQueue(10).

Constructors

new(response : HTTP::Server::Response)
Source

Class methods

queue_size
Source
queue_size=(queue_size : Int32)
Source

Instance methods

abort

Потребитель (клиент) больше не читает: очистить буфер и отменить продюсера — заблокированный write и следующий write поднимут ClientDisconnected.

Source
call_on_error
Source
close

Конец контента от продюсера; pump допивает буфер и завершает ответ (терминатор chunked допишет HTTP::Server::Response#close).

Source
committed?

Заголовки уже ушли (первый write)?

Source
connected?

Клиент ещё на связи?

Source
ignore_disconnect
ignore_disconnect=(ignore_disconnect : Bool)
ignore_disconnect?
Source
on_error
Source
pop

nil = конец (close-семантика) или abort.

Source
pump

Перекачка буфера в сокет: каждый write+flush = отдельный chunk-фрейм. Ошибка сокета (клиент отключился) → abort → отмена fiber'а экшена.

Source
response
write(string : String) : Int32
Source
writeln(string : String) : Nil

То же, что write, но с гарантированной \n на конце.

Source