Refactored observables to use channels
Close channels in GCed event-streams