Module queue 

Bounded and unbounded queues that bridge external producers into a Datum stream.

SourceQueue / BoundedSourceQueue let external code feed elements into a running stream, while SinkQueue lets external code pull materialized results out on demand.

Structs

BoundedSourceQueue

Materialized handle of Source::queue_bounded: a synchronous, bounded, lock-free queue with no overflow strategy (a full buffer drops). Clone; the stream completes when the last handle is dropped.

SinkQueue

Materialized handle of Sink::queue: lets external code pull materialized elements out of a running stream on demand.

SourceQueue

Materialized handle of Source::queue: a bounded queue with a configurable OverflowStrategy. Under Backpressure, maxConcurrentOffers is 1 — offer blocks until buffer space is free and a second concurrent offer errors.

Enums

QueueOfferResult

Outcome of offering one element to a source queue.