the idea is to have an instance `coroutine` method...
# coroutines
k
the idea is to have an instance
coroutine
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