Exception handling in Reducers needs some work

[kanawish]

Received a suggestion to change Observable.just(reducer) usage to

Observable.create{ emitter ->
 val reducer : Reducer<T> = { it.apply(block) }
emitter.onNext(reducer)
emitter.onComplete()
}

The concern being, exceptions are not really being taken in account with current code.

That said, part of my naive thinking has been "crashing reducers? crash the app". Re-evaluate if that actually made sense.