@Test public void testPlaceSubscription() throws Exception { TestSubscriber<Place> testObserver = TestSubscriber.create(); RxOkuki.onPlace(okuki, TestPlace.class).subscribe(testObserver); verify(okuki).addPlaceListener(isA(PlaceListener.class)); testObserver.unsubscribe(); verify(okuki).removePlaceListener(isA(PlaceListener.class)); }
public static <P extends Place> Observable<P> onPlace(Okuki okuki, Class<P> clazz) { return Observable.create(new OnPlaceOnSubscribe<>(okuki, clazz)); }
RxOkuki { public static <P extends Place> Observable<P> onPlace(Okuki okuki, Class<P> clazz) { return Observable.create(new OnPlaceOnSubscribe<>(okuki, clazz)); } }
RxOkuki { public static <P extends Place> Observable<P> onPlace(Okuki okuki, Class<P> clazz) { return Observable.create(new OnPlaceOnSubscribe<>(okuki, clazz)); } private  RxOkuki(); }
RxOkuki { public static <P extends Place> Observable<P> onPlace(Okuki okuki, Class<P> clazz) { return Observable.create(new OnPlaceOnSubscribe<>(okuki, clazz)); } private  RxOkuki(); static Observable<Place> onAnyPlace(Okuki okuki); static Observable<P> onPlace(Okuki okuki, Class<P> clazz); static Observable<Place> onBranch(Okuki okuki, Class<B> clazz); }
RxOkuki { public static <P extends Place> Observable<P> onPlace(Okuki okuki, Class<P> clazz) { return Observable.create(new OnPlaceOnSubscribe<>(okuki, clazz)); } private  RxOkuki(); static Observable<Place> onAnyPlace(Okuki okuki); static Observable<P> onPlace(Okuki okuki, Class<P> clazz); static Observable<Place> onBranch(Okuki okuki, Class<B> clazz);  }