kirillrakhman
07/22/2016, 3:19 PMcoroutine method asyncRx in your lifecycle component like a fragment or activity. you pass that component to your classes and when they need to subscribe to an observable, they call this method so they can await observables. the call to await adds the Subscription for the observable to a CompositeSubscription that is unsubscribed when the component gets destroyed. et voilà - awaitable observables and no more leaks