BroadcastDistinctValueStreamExtensions<T> extension

Convert a DistinctValueStream to a broadcast DistinctValueStream.

on

• DistinctValueStream<T>

Methods

asBroadcastDistinctValueStream() → DistinctValueStream<T>

Convert the this DistinctValueStream into a new DistinctValueStream 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.

asDistinctValueConnectableStream({bool sync = true}) → DistinctValueConnectableStream<T>

Convert the this DistinctValueStream into a DistinctValueConnectableStream 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.