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