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
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< Function(dynamic)T> > -
SeedCallback<
T> = Option< T> Function()