Yeah, I see I misunderstood completely. This shoul...

# rx

[arekolek]

Yeah, I see I misunderstood completely. This should be better:

actions.ofType<Action.AddNote>()
                .switchMapSingle { note ->
                    Single.fromCallable { Note(text = note.nodeText) }
                            .flatMapCompletable { addNoteUseCase.add(it) }
                            .subscribeOn(<http://Schedulers.io|Schedulers.io>())
                            .toSingleDefault<Change>(Change.NoteAddSuccess)
                            .onErrorReturn { Change.NoteAddError(it) }
                }