Expand description
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.