Restrict

constructor(buffer: Int = DefaultBufferSize, overflow: BufferOverflow = BufferOverflow.SUSPEND)

Parameters

buffer

How many actions will be buffered when consumer processes them slower than they are emitted

overflow

How actions that overflow the buffer are handled.