Redux Observable for Kotlin

RxJava2 middleware for action side effects in Redux using "Epics"

Example usage

import ca.hardeep.kotlin.redux.*
import ca.hardeep.kotlin.redux.observable.*

fun main(args: Array<String>) {

    class TestAction: ActionType
    class AnotherTestAction: ActionType
    class EffectTestAction: ActionType

    data class ApplicationState(
        val strings: List<String> = listOf()
    )

    val initialState = ApplicationState()

    val firstReducer = fun(state: ApplicationState, action: Action): ApplicationState {
        return when (action.type::class) {
            TestAction::class -> {
                val newStrings = state.strings.toMutableList()
                newStrings.add("Adding first string")
                return state.copy(strings = newStrings.toList())
            }
            EffectTestAction::class -> {
                val newStrings = state.strings.toMutableList()
                newStrings.add("Adding effect string")
                return state.copy(strings = newStrings.toList())
            }
            else -> {
                state
            }
        }
    }

    val secondReducer = fun(state: ApplicationState, action: Action): ApplicationState {
        return when (action.type::class) {
            AnotherTestAction::class -> {
                val newStrings = state.strings.toMutableList()
                newStrings.add("Adding another string")
                return state.copy(strings = newStrings.toList())
            }
            else -> {
                state
            }
        }
    }

    fun <S> testEpic() : Epic<S> {
        return { action, store, dependencies ->
            action.ofActionType(TestAction())
                    .map({ _ ->
                        Action(EffectTestAction())
                    })
        }
    } 

    val epic = testEpic<ApplicationState>()

    val merged = mergeEpics(epic)

    val combined = combineReducers<ApplicationState>(firstReducer, secondReducer);
    val epicMiddleware = createEpicMiddleware(merged, null)

    val enhancer = applyMiddleware<ApplicationState>(listOf(epicMiddleware))
    val store = createStoreWithEnhancer<ApplicationState>(combined, initialState, enhancer)

    store.dispatch(Action(TestAction()))
    store.dispatch(Action(AnotherTestAction()))

    println(store.getState())
}

// Result: ApplicationState(strings=[Adding first string, Adding effect string, Adding another string])