Class AsyncOnSubscribe.UnicastSubject<T>