Module stream 

Stream related utilities.

Modules

scheduler

Scheduler based multi-stream support.

Structs

GcTask

A task to be enqueue on the gc stream that will be clearned after an event is reached.

MultiStream

Manages multiple streams with synchronization logic based on shared bindings.

ResolvedStreams

Streams that are synchronized correctly after a MultiStream::resolve is called.

StreamPool

Represents a pool of streams, managing a collection of streams created by a factory.

Enums

StreamCaptureState

Where a stream sits in the graph-capture lifecycle, and the only thing allowed to move it. Capture is a strict NoCapture → Prepare → Capture → NoCapture progression, driven by prepare, begin and end; each rejects an out-of-order call, so a capture can never start unprepared and two captures can never overlap on one stream.

Traits

EventStreamBackend

Trait defining the backend operations for managing streams and events.

StreamFactory

Trait for creating streams, used by the stream pool to generate streams as needed.

Functions

stream_index

Maps a stream ID to an index within the pool’s capacity using modulo arithmetic.