ConsumerGroup<T> class
Constructors
-
ConsumerGroup(OffsetIterator<
T> iterator)
Properties
-
children
→ Set<
OffsetIterator< T> > -
The current
OffsetIterator's that are pulling from iterator.no setter - hashCode → int
-
The hash code for this object.
no setterinherited
-
iterator
→ OffsetIterator<
T> -
The wrapped OffsetIterator that consumers will pull from.
final
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
cancel(
) → FutureOr< void> -
Calls
cancelon the wrapper iterator. -
consumer(
{int? startOffset, int retention = 0}) → OffsetIterator< T> -
Create a new OffsetIterator that will pull from the iterator.
It is garanteed not to miss an item, and the parent will have it's
logtrimmed to contain the least amount of items as possible. -
deregister(
OffsetIterator< T> child) → void - Remove a child OffsetIterator from the ConsumerGroup.
-
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited