Uses of Class
rx.observables.AsyncOnSubscribe.UnicastSubject