pardom-zz/redux-observable

Redux RxJava Observable middleware for Kotlin

Redux Observable

Redux RxJava Observable middleware for Kotlin

Download

repositories {
	...
	maven { url "https://jitpack.io" }
}

// RxJava 1
compile 'com.github.pardom.redux-observable:redux-observable:<version>'

// RxJava 2
compile 'com.github.pardom.redux-observable:redux-observable2:<version>'

redux-observable's Issues

Race condition in initalization

Description

If you dispatch an action soon after creating the epic middleware, the returned Observable from the map function needs to start the subscription synchronously. If you subscribe with a different scheduler (subscribeOn), a race condition is created and events could be emitted before subscribers are ready.

Steps to reproduce the behavior

On the "create" test here Tests, make the returned observable subscribe on a different scheduler. Eg. .subscribeOn(Schedulers.io())

Investigation

At this point it is assumed that the actions subject has observers, however the actions.hasObservers() function shows that is not true.
What I think is happening is that since we are subscribing on a different thread in the epic observable, the function continues and emits an item before the observable is ready to receive items.

Middleware will terminal if it faces an exception.

I'm trying integrate redux-kotlin to our app. It works extreme well except when observable middleware. It will stop working if there is some exception are occurred.

How do you guy solve this issue? Thank you so much.