Конкат разных типов наблюдаемых

Question

Я хочу объединить различные наблюдаемые для создания потока активности, используя SQLBrite для сохранения информации в моей базе данных Android Qulite

Этот поток должен следовать этой последовательности действий:

1 - Создайте наблюдаемую ответственность за открытие экземпляра транзакции.

2 - объединить множество наблюдаемых, каждая из которых отвечает за вставку данных в таблицы (по одной наблюдаемой на таблицу)

3.a - если все данные также вставлены (метод doOnCompleted), зарегистрируйте это и установите мой экземпляр транзакции как успешный

3.b - если есть ошибка, зарегистрируйте эту ошибку (метод doOnError)

4 - Закрыть мой экземпляр транзакции (метод doOnTeminate)

Эта проблема:

Такие методы, как doOnError, doOnCompleted и doOnTerminate, не отправляют мой экземпляр транзакции в качестве параметра. Есть способ сделать это?

Answer 1

Я не верю, что вы что-то получаете, делая действие открытия связи заметным. Вот более простой способ решить вашу проблему.

SomeObject transaction=new Transaction();
Observable.concat(obs1,obs2,obs3)
          .doOnCompleted(logStuff())
          .doOnError(e->)
          .doOnTerminate(transaction.close());