publish method

PublishConnectableStream<T> publish()

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.

Example

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();
await Future(() {});

// Stop emitting items from the source stream and close the underlying
// Subject
subscription.cancel();

Implementation

PublishConnectableStream<T> publish() =>
    PublishConnectableStream<T>(this, sync: true);