ursus
Observable.create { emitter -> emitter.onError(FooThrowable()) } .onErrorReturn(..) .downstream...