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

Question

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

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

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

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

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());