Dominaezzz
08/12/2019, 4:34 PMFlow.conflate()
allows emitter to never suspend but is there an operator to allow the collector to never suspend (too)?jw
08/12/2019, 4:37 PM.buffer(UNLIMITED)
?Dominaezzz
08/12/2019, 4:38 PMjw
08/12/2019, 4:40 PMwhile (true) { send(latest) }
in its own coroutine separate from the collector which updates latest (for conflate-like behavior).Dominaezzz
08/12/2019, 4:42 PMFlow<Boolean>
(a stream of connection statuses) and Flow<Task>
(a stream of tasks). I need to process the flow of tasks while the latest value from the first flow is true
.transformLatest
.Zach Klippenstein (he/him) [MOD]
08/14/2019, 5:51 PMwithLatestFrom
operator, as in RxJava? (Doesn't exist for flow right now)