Как бороться с распространением ошибок через lambda - PullRequest
Новая
       6

Как бороться с распространением ошибок через lambda

0 голосов
/ 08 января 2019

Приведенный ниже код печатает один UndeliverableException для второго потока внутри метода publish. 

PublishSubject<Integer> subject = PublishSubject.create();
subject
    .publish(shared ->
        Observable.merge(
            shared.filter(i -> i == 1),
            shared.filter(i -> i == 2)))
    .onErrorReturnItem(5)
    .subscribe();

subject.onError(new IOException());

Как сделать так, чтобы он не считал этот недоставленным, и при этом мог бы реагировать на все ошибки одним "поймать их всех" onErrorReturnItem в конце?

...