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)