knot_together.kt

val eventsFromView = viewEvents.map { viewEvent ->
    when (viewEvent) {
        is SampleViewEvent.TodoCheckedViewEvent ->
            Event.TodoCheckedEvent(viewEvent.id, viewEvent.isChecked)
        is SampleViewEvent.TodoAddedViewEvent ->
            Event.NewTodoEvent(viewEvent.text)
    }
}
val dbEvents = db.todoDao().getAll().toObservable().map(::DbUpdateEvent)
val externalEvents = Observable.merge(eventsFromView, dbEvents)
val transformer = Transformer<State, Event, Event> { upstream ->
    upstream
            .doOnNext {
                Log.d("SampleViewModel", "Event: ${it.third}")
                Log.d("SampleViewModel", "State: ${it.second}")
            }
            .publish { shared ->
        Observable.merge(
                shared.compose(addNewTodoEffect),
                shared.compose(checkTodoEffect),
                shared.compose(viewStateEffect)
        )
    }
}
val events = createConnectableKnot(
        State(listOf()),
        externalEvents,
        this::reducer,
        transformer
)
viewState = events.ofType(Event.ViewStateEvent::class.java)
        .map { it.viewState }
        .replay()
        .autoConnect(-1)
events.connect()