BackPressureStrategy

data class BackPressureStrategy(val capacity: Int, val onThresholdReached: () -> Unit, val onItemDropped: (Any) -> Unit, val backpressureMitigation: BackPressureMitigation)

Parameters


capacity	the maximum size of the queue
onThresholdReached	callback called when the queue reaches full capacity
onItemDropped	called when an item is dropped because of this backpressure strategy
backpressureMitigation	the mitigation to use when reaching the capacity

Constructors

BackPressureStrategy

constructor(capacity: Int, onThresholdReached: () -> Unit, onItemDropped: (Any) -> Unit, backpressureMitigation: BackPressureMitigation)

Parameters


capacity	the maximum size of the queue
onThresholdReached	callback called when the queue reaches full capacity
onItemDropped	called when an item is dropped because of this backpressure strategy
backpressureMitigation	the mitigation to use when reaching the capacity