В статье не написано, что на Observable можно подписаться с помощью
.subscribe(Consumer<? super T> onNext)
.subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError)
.subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)
Каждый из этих методов возвращает Disposable.
Используя эти методы, мы можем переписать этот код:
Observable<String> o = Observable.just(“Hello”);
Disposable d = new o.subscribeWith(new DisposableObserver<String>() {
@Override public void onNext(String s) { … }
@Override public void onComplete() { … }
@Override public void onError(Throwable t) { … }
});
d.dispose();
На такой:
Observable<String> o = Observable.just("Hello");
Disposable d = o.subscribe(s -> {}, throwable -> {}, () -> {});
d.dispose();
Могу порекомендовать книгу «Нуркевич, Кристенсен: Реактивное программирование с использованием RxJava». В ней достаточно подробно описаны операторы + приведены примеры по их использованию.
на такой:
К тому же с помощью AndroidInjection можно добавить активити/фрагмент в граф даггера и использовать их для инъекций.
Каждый из этих методов возвращает Disposable.
Используя эти методы, мы можем переписать этот код:
На такой: