BackpressureStrategy<Q, R> class abstract

Class to implement to support a backpressure strategy. This is used to make sure job queues are handled properly.

Examples of implementations of this class are: NoBackPressureStrategy that uses a FIFO stack for handling backpressure. ReplaceBackpressureStrategy that has a job queue with size one, and discards the queue upon adding a new job. DiscardNewBackPressureStrategy that has a job queue with size one, and as long as the queue is populated a new job will not be added. CombineBackPressureStrategy that has a job queue with size one, and uses a combine function to combine input data on back pressure.





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


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


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