darkmoon_uk
12/21/2021, 3:11 PMflatMap-
family operator that ignores new upstream emissions while a mapping operation is being processed (i.e. mapped stream is not completed)? How could this be achieved? I don't want emissions buffered as with concat
, but thrown away/ignored.Nick Allen
12/21/2021, 3:56 PMbuffer
operator before flatMap-
. I think you want buffer(Channel.RENDEZVOUS, BufferOverflow.DROP_LATEST)
Nick Allen
12/21/2021, 3:59 PMflatMapConcat
doesn’t buffer anything. It’s the Flow
you applied the operator on that is doing the buffering.darkmoon_uk
12/22/2021, 12:01 AMNick Allen
12/22/2021, 12:08 AMDROP_OLDEST
with DROP_LATEST
in earlier comment.