QueueWorker<TEvent> class
The class handles the dataQueue with built-in commands.
Constructors
-
QueueWorker(DataQueue<
TEvent> dataQueue) - Creates QueueWorker handles the dataQueue with built-in commands.
Properties
-
all
→ Future<
List< TEvent> > -
Returns all events from the dataQueue.
no setter
-
clone
→ Future<
TEvent> -
Returns an event from the dataQueue without consuming it.
no setter
-
count
→ Future<
int> -
Returns an event count in the dataQueue.
no setter
-
dataQueue
→ DataQueue<
TEvent> -
The Data queue
final
- hashCode → int
-
The hash code for this object.
no setterinherited
-
next
→ Future<
TEvent> -
Returns next event in the dataQueue.
no setter
- runtimeType → Type
-
A representation of the runtime type of the object.
no setterinherited
Methods
-
add(
TEvent event) → void -
Adds the
eventto the events queue. -
addAll(
List< TEvent> events) → void -
Adds all
eventsto the events queue in the iteration order. -
noSuchMethod(
Invocation invocation) → dynamic -
Invoked when a nonexistent method or property is accessed.
inherited
-
skip(
int count) → Future< int> -
Skips the next
countevents in the dataQueue -
take(
int count) → Future< List< TEvent> > -
Returns a list with the next
countevents from the dataQueue -
terminate(
) → void -
Terminates all commands by throwing the
TerminateException. -
toString(
) → String -
A string representation of this object.
inherited
Operators
-
operator ==(
Object other) → bool -
The equality operator.
inherited