public class RxBus {

private static final RxBus INSTANCE = new RxBus();private final Subject
    
      mBusSubject = new SerializedSubject<>(PublishSubject.create());public static RxBus getInstance() {    return INSTANCE;}public 
     
       Subscription register(final Class
      
        eventClass, Action1
       
         onNext) {    return mBusSubject            .filter(event -> event.getClass().equals(eventClass))            .map(obj -> (T) obj)            .subscribe(onNext);}public void post(Object event) {    mBusSubject.onNext(event);}
       
      
     
    

}