kevin.cianfarini
02/10/2020, 3:53 PMchannelFlow
doesn't expose something like fun channelFlow(buffer: Int = ...)
And instead we have to call .buffer
downstream?Zach Klippenstein (he/him) [MOD]
02/10/2020, 4:02 PMchannelFlow(buffer = UNLIMITED) {
…
}.conflate()
Because the two buffer specifications would compete (since the operators are fused under the hood and use a single channel), and only one of the specifications would actually be used.kevin.cianfarini
02/10/2020, 4:03 PMreturn if (this is ChannelFlow)
update(capacity = capacity)
else
ChannelFlowOperatorImpl(this, capacity = capacity)
Adjacent applications of channelFlow, flowOn, buffer, produceIn, and broadcastIn are always fused so that only one properly configured channel is used for execution.