kevin.cianfarini
02/07/2025, 9:31 PMchannelFlow { ... }.conflate().buffer(3, onBufferOverflow = Suspend)
will configure the underlying channel to have a size of three with an overflow strategy of DROP_OLDEST
. The documentation mentions the following:
Conflation takes precedence over buffer() calls with any other capacity.Is it a bug that my configured channel has a size of three, or does the above piece of documentation only apply to the buffer overflow strategy?
kevin.cianfarini
02/07/2025, 9:31 PMkevin.cianfarini
02/07/2025, 9:52 PMchannelFlow { ... }.conflate().buffer(3, onBufferOverflow = Suspend)
I’m seeing the following values in the debugger. This seems really unintuitive based on the documentation and therefore I think this might be a bug.Dmitry Khalanskiy [JB]
02/10/2025, 3:37 PMkevin.cianfarini
02/10/2025, 3:44 PMconflate
can't make that guarantee, then I'll have to fall back to the regular flow
builder with a manually configured channel.kevin.cianfarini
02/11/2025, 3:18 PMDmitry Khalanskiy [JB]
02/12/2025, 7:35 AMkevin.cianfarini
02/12/2025, 1:58 PM