ValueConnectableNotReplayStreamExtensions<T> extension

Extension that converts a Stream into NotReplayValueConnectableStream and NotReplayValueStream.

on

• Stream<T>

Methods

publishValueNotReplay(T seedValue, {bool sync = true}) → NotReplayValueConnectableStream<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.

shareValueNotReplay(T seedValue) → NotReplayValueStream<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.