BackpressureController

class BackpressureController(strategy: BackpressureStrategy = BackpressureStrategy.SUSPEND, highWatermark: Int = 8000, lowWatermark: Int = 2000, currentSize: Int = 0)(source)

Constructors

Link copied to clipboard
constructor(strategy: BackpressureStrategy = BackpressureStrategy.SUSPEND, highWatermark: Int = 8000, lowWatermark: Int = 2000, currentSize: Int = 0)

Functions

Link copied to clipboard
Link copied to clipboard
fun disable()
Link copied to clipboard
fun enable()
Link copied to clipboard
Link copied to clipboard
fun recordQueueSize(size: Int)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard