RxBus

RxBus

import rx.Observable;
import rx.subjects.PublishSubject;
import rx.subjects.SerializedSubject;
import rx.subjects.Subject;

public class RxBus {

  private final Subject<Object, Object> bus = new SerializedSubject<>(PublishSubject.create());

  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> Observable<T> toObservable (Class<T> eventType) {
    return bus.ofType(eventType);
  }
}