SampleStreamTransformer<T> class

A StreamTransformer that, when the specified window Stream emits an item or completes, emits the most recently emitted item (if any) emitted by the source Stream since the previous emission from the sample Stream.

Example

new Stream.fromIterable([1, 2, 3])
  .transform(new SampleStreamTransformer(new TimerStream(1, const Duration(seconds: 1)))
  .listen(print); // prints 3

Constructors

SampleStreamTransformer(Stream window(T event))

Properties

hashCode → int
The hash code for this object.
read-only, inherited
runtimeType → Type
A representation of the runtime type of the object.
read-only, inherited
transformer → StreamTransformer<T, T>
final, inherited

Methods

bind(Stream<T> stream) → Stream<T>
Transforms the provided stream.
inherited
cast<RS, RT>() → StreamTransformer<RS, RT>
Provides a StreamTransformer<RS, RT> view of this stream transformer.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed.
inherited
toString() → String
Returns a string representation of this object.
inherited

Operators

operator ==(dynamic other) → bool
The equality operator.
inherited