BothObservable.fromEmitter
Pedro Diaz
11

Hi Pedro, thanks for the response! Observable.create(Action1, BackpressureMode) is a RxJava 2.x API while this article only pertains to RxJava 1.2.6+. RxJava 2 has certainly simplified constructing Observables / Flowables in a safe manner.

One clap, two clap, three clap, forty?

By clapping more or less, you can signal to us which stories really stand out.