offset_iterator_riverpod library

Classes

AwaitableSink<T>
AwaitableSink is an EventSink that allows you to wait for the data to be consumed.
ConsumerGroup<T>
DrainableSink<T>
DrainableSink is an AwaitableSink that allows the consumer to start draining the internal pipeline.
OffsetIterator<T>
OffsetIteratorAsyncValue<T>
OffsetIteratorController<T>
OffsetIteratorController implements sink behaviour and wraps an OffsetIterator.
OffsetIteratorState<T>
OffsetIteratorValue<T>
Option<T>
Represents a value that could be missing - an [option]al value.

Functions

iteratorLatestValueProvider<T>(ProviderRef<OffsetIteratorValue<Option<T>>> ref) → OffsetIteratorValue<Option<T>> Function(OffsetIterator<T> iterator)
Listens to an OffsetIterator, and updates the exposed OffsetIteratorValue whenever it changes.
iteratorProvider<T>(ProviderRef<OffsetIterator<T>> ref) → OffsetIterator<T> Function(OffsetIterator<T> iterator)
iteratorValueProvider<T>(ProviderRef<OffsetIteratorAsyncValue<T>> ref, {int initialDemand = 1}) → OffsetIteratorAsyncValue<T> Function(OffsetIterator<T> iterator)
Pulls an OffsetIterator on demand, and exposes the most recently pulled OffsetIteratorAsyncValue.

Typedefs

CleanupCallback = FutureOr<void> Function(dynamic)
InitCallback = FutureOr Function()
OffsetIteratorControllerTransform<T> = OffsetIterator Function(OffsetIterator<T>)
Optional transformation to apply to the wrapper OffsetIterator
ProcessCallback<T> = FutureOr<OffsetIteratorState<T>> Function(dynamic)
SeedCallback<T> = Option<T> Function()