Исследуем RxJava 2 для Android

[Mihail57]

Одно из самых понятных введений в RxJava, имхо. Огромное спасибо автору за такой подробный пост.

[Valeroncho]

В статье не написано, что на 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();

[Firsto]

Итак, единственная разница между двумя этими типами заключается в том, что один поддерживает backpressure, а другой — нет.

Расскажите подробнее, в каких ситуациях это требуется. Никак не могу понять, нужен ли мне Flowable.

[filatoff]

Если вы знакомы с RxJava 1, то вы помните его – этот тот самый ужасный метод, который никогда не следует использовать в RxJava 1.

Можете подробнее рассказать, почему этот метод нельзя никогда использовать. У меня с ним не возникало видимых проблем. Возможно, я что-то не понимаю )

[danikula]

Эталонное описание.