rx_samplers library

Functions

onCount<T, S>(int count, [ int startBufferEvery = 0 ]) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnCountSampler which matches the method signature of buffer and window. [...]
onFuture<T, S, O>(Future<O> onFuture()) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnStreamSampler which matches the method signature of buffer and window. [...]
onStream<T, S, O>(Stream<O> onStream) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnStreamSampler which matches the method signature of buffer and window. [...]
onTest<T, S>(bool onTest(T event)) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnTestSampler which matches the method signature of buffer and window. [...]
onTime<T, S>(Duration duration) → Stream<S> Function(Stream<T> stream, OnDataTransform<T, S> , OnDataTransform<S, S> )
Higher order function implementation for _OnStreamSampler which matches the method signature of buffer and window. [...]

Typedefs

OnDataTransform<T, S>(T event, EventSink<S> sink, [ int skip ]) → void
SamplerBuilder<T, S>(Stream<T> stream, OnDataTransform<T, S> bufferHandler, OnDataTransform<S, S> scheduleHandler) → Stream<S>
Higher order function signature which matches the method signature of buffer and window.