amrelmasry
03/29/2018, 10:52 AMstartWith
on the stream before calling openSubscription()
but I will be forced to move the time consuming operation above also, to generate stream of Result
instead of Stream of Event
and I am trying to make coroutines handle the logic instead (I am trying to replace complex RxJava chains with coroutines)