distinct_value_connectable_stream library

Extensions

BroadcastDistinctValueStreamExtensions on DistinctValueStream<T>

Convert a DistinctValueStream to a broadcast DistinctValueStream.

DistinctValueConnectableExtensions on Stream<T>

Provide two extension methods for Stream:

ToDistinctValueStreamExtension on Stream<T>

Convert this Stream to a DistinctValueStream.

Typedefs

DistinctValueConnectableStream<T> = StateConnectableStream<T>

A ConnectableStream that converts a single-subscription Stream into a broadcast Stream, and provides synchronous access to the latest emitted value.

DistinctValueStream<T> = StateStream<T>

An Stream that provides synchronous access to the last emitted item, and two consecutive values are not equal. The equality between previous data event and current data event is determined by equals.

DistinctValueSubject<T> = StateSubject<T>

A special StreamController that captures the latest item that has been added to the controller.