offset_iterator library Null safety

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>
OffsetIteratorController<T>
OffsetIteratorController implements sink behaviour and wraps an OffsetIterator.
OffsetIteratorState<T>
Option<T>
Represents a value that could be missing - an [option]al value.

Extensions

AccumulateExtension
AccumulateIListExtension
AsyncMapExtension
BufferExtension
ConsumerGroupExtension
DistinctExtension
DoubleExtension
EitherExtension
FlatMapExtension
FoldExtension
HandleErrorExtension
IntExtension
LastExtension
ListenExtension
MapExtension
OptionExtension
PipeExtension
PrefetchExtension
RunExtension
ScanExtension
StartFromExtension
TakeUntilExtension
TakeWhileExtension
TapExtension
ToIListExtension
ToListExtension
TransformConcurrentExtension
TransformExtension

Enums

OffsetIteratorControllerState
OffsetIteratorStatus

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()