rx_samplers library
Functions
-
onCount<T, S>(int count, [ int skip ])
→ 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.
