buffer

fun <I, O> Exchange<I, O>.buffer(capacity: Int = Channel.BUFFERED): Exchange<I, O>

Transforms an Exchange by buffering its contents. This buffers the underlying flows in both directions.

See also

the buffer operator on the underlying Flow.

Parameters

capacity

the capacity of the buffer.