RxJava Event Bus
android, rx-android, rx-java, rx-java2
Solution
In RxJava2, the `Action1` has been renamed to `Consumer`.
The remaining action interfaces were named according to the Java 8 functional types. The no argument `Action0` is replaced by the `io.reactivex.functions.Action` for the operators and `java.lang.Runnable` for the `Scheduler` methods. `Action1` has been renamed to `Consumer` and `Action2` is called `BiConsumer`. `ActionN` is replaced by the `Consumer<Object[]>` type declaration.
See What's different in 2.0
Problem
Using first version of `RxJava` and `RxAndroid` I had following `class` as `EventBus`: ``` public class RxBus { private static RxBus instance; private PublishSubject<Object> subject = PublishSubject.create(); public static RxBus instanceOf() { if (instance == null) { instance = new RxBus(); } return instance; } public void setMessage(Object object) { subject.onNext(object); } public Observable<Object> getEvents() { return subject; } } ``` Getting instance via `instanceOf` in any class I used `setMessage` method to emit messages and following code to get emitted messages: ``` bus.getEvents().subscribe(new Action1<Object>() { @Override public void call(Object o) { if (o instanceof String) { //TODO } } }); ``` `Action1` was from `rx.functions` package. Trying to migrate use `RxJava 2` I cannot import it. Tell me please, what is the shortest way to use `RxJava 2` as `EventBus`