DistinctValueConnectableExtensions<T> extension

Provide two extension methods for Stream:

• publishValueDistinct
• shareValueDistinct

on

• Stream<T>

Methods

publishValueDistinct(T seedValue, {bool equals(T previous, T next)?, bool sync = true}) → DistinctValueConnectableStream<T>

Convert the this Stream 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.

shareValueDistinct(T seedValue, {bool equals(T previous, T next)?, bool sync = true}) → DistinctValueStream<T>

Convert the this Stream 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.