Nie można zasubskrybować na RxJava 2 Obserwować za pomocą TestSubscriber

Question

Dlaczego mój kompilator nie pozwala sobie na zasubskrybowanie w Obserwatorium za pomocą TestSubscribera?

Oto mój kod:

TestSubscriber<User> testSubscriber = new TestSubscriber<>(); 
Observable.just(new User()).subscribe(testSubscriber); 

A ona mówi, że nie można rozwiązać metodą subscribe który bierze ten parametr. Ale we wszystkich tutorialach testowych RxJava używają TestSubscriber bez takich problemów. Co mogę zrobić, aby przetestować takie obserwowalne?

Answer 1

Jest tak, ponieważ *Subscriber są przeznaczone dla Flowable, podczas gdy Observable używa klas *Observer. Wynika to z faktu, że standard strumieni reaktywnych rezerwuje Subscriber dla w pełni zgodnego interfejsu Publisher, który jest implementowany.

Dodatkowo z RxJava2 wszystkie klasy reaktywne mają metodę .test(), która bezpośrednio da ci odpowiedni obiekt testowy.