publish method Null safety
Convert the current Stream into a
ConnectableStream that can be listened
to multiple times. It will not begin emitting items from the original
Stream until the
connect method is invoked.
This is useful for converting a single-subscription stream into a broadcast Stream.
final source = Stream.fromIterable([1, 2, 3]); final connectable = source.publish(); // Does not print anything at first connectable.listen(print); // Start listening to the source Stream. Will cause the previous // line to start printing 1, 2, 3 final subscription = connectable.connect(); // Stop emitting items from the source stream and close the underlying // Subject subscription.cancel();
ConnectableStream<T> publish() => PublishConnectableStream<T>(this, sync: true);