Module streaming 

Streaming infrastructure for SSE responses and event queues.

Modules

event_queue

Event queue for server-side streaming.

sse

Server-Sent Events (SSE) response builder.

Structs

EventQueueManager

Manages event queues for active tasks.

InMemoryQueueReader

In-memory EventQueueReader backed by an mpsc channel receiver.

InMemoryQueueWriter

In-memory EventQueueWriter backed by an mpsc channel sender.

SseBodyWriter

Wraps an mpsc::Sender for writing SSE frames to a response body.

Constants

DEFAULT_MAX_EVENT_SIZE

Default maximum event size in bytes (16 MiB).

DEFAULT_QUEUE_CAPACITY

Default channel capacity for event queues.

Traits

EventQueueReader

Trait for reading streaming events.

EventQueueWriter

Trait for writing streaming events.

Functions

build_sse_response

Builds an SSE streaming response from an event queue reader.