Module stream

Expand description

Stream related utilities.

Re-exports§

base: The pool of backend streams, and the primitives that record on their memory what a unit of work did or did not write.
scheduler: Scheduler based multi-stream support.

EventStreamBackendWrapper: The factory a MultiStream’s pool is built from. Public only because it names the pool in FailureStore::Factory; it has no surface of its own.
ExecuteScope: One scope around a unit of device work.
Failures: Every failure a device is still holding, plus the little a write scope needs around them.
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.
StreamCapture: The graph capture of one pooled backend stream: where it sits in the lifecycle, and the memory its recorded launches were given.
StreamWrapper: A wrapper around a backend stream that includes synchronization metadata.

CaptureEnd: What StreamCapture::end found when it closed the window: the caller’s own capture, or one belonging to a logical stream that never came back to close it.
ScopedOutcome: What a scope’s work did.

EventStreamBackend: Trait defining the backend operations for managing streams and events.
FailureStore: A multi-stream driver that owns a device’s Failures.
WriteScoped: A server whose device work runs inside an ExecuteScope.

failed_writing: Claim written for error without running anything: work that never started leaves its destinations exactly as they were, so a read of one of them has to fail on the error that stopped it.