RxBus2

public class RxBus {

  private final FlowableProcessor<Object> bus = PublishProcessor.create().toSerialized();

  private RxBus() {
  }

  private static class InstanceHolder {
    private static final RxBus sInstance = new RxBus();
  }

  public static RxBus getInstance() {
    return InstanceHolder.sInstance;
  }

  public void send(Object o) {
    bus.onNext(o);
  }

  public <T> Flowable<T> toFlowable(Class<T> eventType) {
    return bus.ofType(eventType);
  }
}