kaskade.kt

Kaskade.create<ListAction, ListState>(ListState.Screen()) {
    rx({
        object : DisposableObserver<ListState>() {
            override fun onComplete() {
                Timber.d("flow completed")
            }

            override fun onNext(state: ListState) {
                Timber.d("currentState = $state")
            }

            override fun onError(e: Throwable) {
                Timber.e(e, "Flow was interrupted")
                process(ListAction.OnError(e).just())
            }
        }.also { disposables.add(it) }
    }) {
        on<ListAction.Refresh> {
            // get first 20 trending giphies from network
        }

        on<ListAction.LoadMore> {
            // get next 20 trending giphies from network based on offset
        }
    }

    on<ListAction.OnItemClick> {
        ListState.GoToDetail(action.item)
    }

    on<ListAction.OnError> {
        ListState.Error(R.string.error_loading)
    }
}