stream property

Stream<Sample> get stream

A stream of Samples received by this advanced subscriber.

Lifetime. This stream is bound to this entity: close completes it. If the session is closed while this subscriber is still open, the stream goes quiet without completing — no more samples arrive, but no done is delivered either, because nothing posts a completion sentinel on this path. That differs from detectedPublishers, whose listener canon owns at session scope and which therefore does complete; the asymmetry is canon's, not this binding's. ⚠️ UNBOUNDED, and pausing it does not stop the flow — see Session.declareSubscriber for the measurement. This family has no bounded entry point at all: there is no channel-mode advanced subscriber, so unlike the plain surfaces there is no bounded alternative to point you at. That gap is carved rather than fixed here, and it is tracked as parity debt.

Implementation

Stream<Sample> get stream => _sampleChannel.stream;