class

Grip::ServerSent::Stream

Constructors

new(context : HTTP::Server::Context, capacity : Int32 = 100, strategy : Strategy = Strategy::DropOldest)

await(interval : Time::Span = 15.seconds) : Nil

Keeps the SSE handler fiber alive by sending periodic heartbeats.

capacity

comment(text : String) : self

connected(connection_id : String) : self

Protocol-level Connection Acknowledgment

context

emit(type : Event::Type, data : T = nil, *, id : String | Int | Nil = nil, retry : Time::Span | Nil = nil) : self forall T

error(data : T = nil) : self forall T

Protocol-level Error Emitting

ping

Protocol-level Heartbeat

send(data : String, *, event : String | Nil = nil, id : String | Int | Nil = nil, retry : Time::Span | Nil = nil) : self

Formats and enqueues the payload without blocking the caller fiber (unless using strategy: Block).

strategy