RxJava - Where did AbstractOnSubscribe go in 1.1.0?

Question

Version 1.1.0 just came out and it looks like they dropped rx.observables.AbstractOnSubscribe

Removals from Public API

• Observable.onBackpressureBlock
• rx.observables.AbstractOnSubscribe
• Removal of stateful methods from the generic rx.subjects.Subject abstract class

AbstractOnSubscribe was my preferred way of creating non-trivial observables. Why was it removed, and what's can I replace it with?

Answer 1

AbstractOnSubscribe was marked as experimental thus always carried the chance of being removed.

The class has been replaced by SyncOnSubscribe which works roughly the same but with internals that have lower overhead; this required API changes (i.e., thinner API than the State object).

You can use the many factory methods to create your OnSubscribe instance or extend SyncOnSubscribe directly.