GHLoginSingleSubscriber.kt

typealias GHLoginObservableType = Pair<LoginResultAction,Store<StateType>>
fun getGHLoginSingleSubscriber(): SingleObserver<GHLoginObservableType> {
    return object : SingleObserver<Pair<LoginResultAction,Store<StateType>>> {

        override fun onSubscribe(d: Disposable) {}

        override fun onSuccess(value: GHLoginObservableType) {

            val (loginResultAction,store) = value
            if (loginResultAction.loginStatus == LoggedInState.notLoggedIn) {
                store.dispatch(LoginFailedAction(userName = loginResultAction.userName,
                        message = loginResultAction.message as String))

            } else {
                store.dispatch(LoginCompletedAction(loginResultAction))
                store.dispatch(LoggedInDataSaveAction(userName = loginResultAction.userName,
                        token = loginResultAction.token as String, loginStatus = LoggedInState.loggedIn))
            }

        }

        override fun onError(e: Throwable) {
            mainStore.dispatch(LoginFailedAction(userName = "",
                    message = "Internal Error"))
        }
    }
}