RxBus.Java
public class RxBus {
private static RxBus myInstance = new RxBus();
private final Subject<Object, Object> _bus = new SerializedSubject<>(PublishSubject.create());
...
public static RxBus singleton() {
if (myInstance == null) {