Доступ к элементу, вызвавшему исключение - PullRequest
Новая
       14

Доступ к элементу, вызвавшему исключение

0 голосов
/ 08 июля 2019

В моем потоке RxJava, если возникает исключение, я хотел бы получить доступ к элементу, вызвавшему исключение. Например, 

val msgToSendPublisher = PublishSubject.create<MessageToSend>()

msgToSendPublisher.flatMap { _ -> App.context.repository.getMessageToSend() }
    .onErrorReturnItem { item ->
        item
    }
    .flatMap { connections ->
        App.context.repository.storeConnections(connections)
    }
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        { connectionDetails ->

        },
        { ex ->

        },
        {
            onConnectionsRetrieved()
        }
    )

В onErrorReturnItem я хотел бы получить доступ к объекту MessageToSend, но это не представляется возможным. Есть ли какой-нибудь другой оператор RxJava, который позволяет мне перехватывать исключение и ссылаться на объект, который был испущен?

...