И
private Observable saveItems(List<Integer> inItems) {
return Observable
.fromIterable(inItems)
.map(item -> item + 2)
.flatMap(item -> {
itemsDao.insert(item);
return Observable.just(true);
});
}
Но не срабатывает doFinally после сабскайба.
saveItems()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doFinally(() -> Log.i(...))
.subscribe();
