stream property

@override Stream<ChannelSnapshot> get stream

Replays the current snapshot, then emits changes.

Implementation

@override
Stream<ChannelSnapshot> get stream => Stream.multi((sink) {
  final sub = _snapshots.stream.listen(sink.add, onDone: sink.close);
  sink.add(snapshot);
  sink.onCancel = sub.cancel;
});