For `Flow.buffer()` there’s `BufferOverflow` `.SUS...
# flow
m
For 
Flow.buffer()
 there’s 
BufferOverflow
 
.SUSPEND
.DROP_OLDEST
 and 
.DROP_LATEST
. Is there a way to fail if the buffer is full and stop the collector?
s
You would need your own custom operator that buffers the values and throws an exception if the buffer is full. If using BufferOverflow.SUSPEND then calls to send items to the collector will be suspended until more room opens up in the buffer