ConnectableStreamExtensions<T> extension

Extends the Stream class with the ability to transform a single-subscription Stream into a ConnectableStream.

on

• Stream<T>

Methods

publish() → PublishConnectableStream<T>

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.

publishReplay({int? maxSize}) → ReplayConnectableStream<T>

Convert the current Stream into a ReplayConnectableStream that can be listened to multiple times. It will not begin emitting items from the original Stream until the connect method is invoked.

publishValue() → ValueConnectableStream<T>

Convert the current Stream into a ValueConnectableStream that can be listened to multiple times. It will not begin emitting items from the original Stream until the connect method is invoked.

publishValueSeeded(T seedValue) → ValueConnectableStream<T>

Convert the current Stream into a ValueConnectableStream that can be listened to multiple times, providing an initial seeded value. It will not begin emitting items from the original Stream until the connect method is invoked.

share() → Stream<T>

Convert the current Stream into a new Stream that can be listened to multiple times. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.

shareReplay({int? maxSize}) → ReplayStream<T>

Convert the current Stream into a new ReplayStream that can be listened to multiple times. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.

shareValue() → ValueStream<T>

Convert the current Stream into a new ValueStream that can be listened to multiple times. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.

shareValueSeeded(T seedValue) → ValueStream<T>

Convert the current Stream into a new ValueStream that can be listened to multiple times, providing an initial value. It will automatically begin emitting items when first listened to, and shut down when no listeners remain.