Is there a flatMap variant which drops upstream emits when body is not completed yet Is overriding ...

# coroutines

[ursus]

Is there a flatMap variant which drops upstream emits when body is not completed yet

Is overriding concurrency to 1 in flatMapMerge okay or should I have a custom operator

[wasyl]

Is there a flatMap variant which drops upstream emits when body is not completed yet

flatMapLatest

[ursus]

no I mean upstream, not downstream

[Zach Klippenstein (he/him) [MOD]]

Use one of the other operators before your flat map: buffer or conflate.

[ursus]

how would I use buffer? is there a way for the buffer to be signalled when downstream emits? i.e how would buffer know when to stop buffering (& dropping). I'm only aware of time or size buffering

[Zach Klippenstein (he/him) [MOD]]

you probably just want conflate if you want to drop all but the latest element

[ursus]

I'm not aware of that, i'll try thanks!