NoBackPressureStrategy<Q, R> class

An implementation of BackpressureStrategy that uses a FIFO stack for handling backpressure.

This strategy has the potential of overflowing the memory as it just keeps piling them up, without discarding any jobs while running.

Marble diagram to visualize timeline:

--a---b---c---d---e---f---------------|

------a-----b-----c-----d-----e-----f-|

Inheritance

Constructors

NoBackPressureStrategy()

Properties

hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

add(BackpressureConfiguration<Q, R> configuration) → void
Adds another job to the queue.
override
dispose() → void
Clears the queue and cleans up.
override
drop(BackpressureConfiguration configuration) → void
Drops the job item, completing it with an error.
inherited
hasNext() bool
Function that returns true if the back pressure strategy has a job in queue.
override
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
takeNext() → BackpressureConfiguration<Q, R>
Function that returns the next job in queue.
override
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited