Share

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

Parameters

buffer

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

replay

How many actions will be replayed to each new subscriber

overflow

How actions that overflow the buffer are handled.