offset_iterator 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>

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.

Enums

OffsetIteratorControllerState

OffsetIteratorStatus

Extensions

AccumulateExtension on OffsetIterator<List<T>>

AccumulateIListExtension on OffsetIterator<IList<T>>

AsyncMapExtension on OffsetIterator<T>

BufferExtension on OffsetIterator<T>

ConsumerGroupExtension on OffsetIterator<T>

DistinctExtension on OffsetIterator<T>

DoubleExtension on OffsetIterator<double>

EitherExtension on OffsetIterator<T>

FlatMapExtension on OffsetIterator<T>

FoldExtension on OffsetIterator<T>

HandleErrorExtension on OffsetIterator<T>

IntExtension on OffsetIterator<int>

LastExtension on OffsetIterator<T>

ListenExtension on OffsetIterator<T>

MapExtension on OffsetIterator<T>

OptionExtension on Option<A>

PipeExtension on OffsetIterator<T>

PrefetchExtension on OffsetIterator<T>

RunExtension on OffsetIterator

ScanExtension on OffsetIterator<T>

StartFromExtension on OffsetIterator<T>

TakeUntilExtension on OffsetIterator<T>

TakeWhileExtension on OffsetIterator<T>

TapExtension on OffsetIterator<T>

ToIListExtension on OffsetIterator<T>

ToListExtension on OffsetIterator<T>

TransformConcurrentExtension on OffsetIterator<T>

TransformExtension on OffsetIterator<T>

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