vince
05/04/2023, 7:58 AMChannel
's onUndeliveredElement
param, except for conflate()
?
I'm trying to emit some values through a Flow that need to be `close()`d, however there is backpressure build up and I would like to close()
the values that are dropped by conflate()
.
Since I'm using callbackFlow
the closest I could come up with is to trySend()
and close()
if that fails, but that will have the behavior equivalent of DROP_LATEST
, while I'm really looking for DROP_OLDEST
.Leo Delon
05/04/2023, 8:20 AMvince
05/04/2023, 9:28 AM