Implementation of bus with RxJava with simple example

FetchPointsRxEvent.java

/**
 *
 * After receiving {@link FetchPointsRxEvent} receiver must to update views with points count
 *
 * 21.04.16
 * Created by Victor Ponomarenko
 */
public class FetchPointsRxEvent {
}

RxBus.java

/**
 * 21.04.16
 * Created by Victor Ponomarenko
 */
public final class RxBus {
    private final Subject<Object, Object> bus = new SerializedSubject<>(PublishSubject.create());

    public static RxBus instance() {
        return Loader.INSTANCE;
    }

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

    private Observable<Object> toObservable() {
        return bus;
    }

    @SuppressWarnings("unchecked cast")
    public <T> Observable<T> filter(final Class<T> eventClass){
        return toObservable()
                .filter(event-> event.getClass().equals(eventClass))
                .map(event-> (T)event);
    }

    private static final class Loader {
        private static final RxBus INSTANCE = new RxBus();
    }
}

Usage.java

// Send event

onEvent(BindState.BOUND)
    .flatMap(boundState ->  view().onEvent(FragmentState.CREATED))
    .subscribe(createState -> {
        RxBus.instance().send(new FetchPointsRxEvent());
    });
    
// Subscribe to event
RxBus.instance().filter(FetchPointsRxEvent.class)
    .observeOn(AndroidSchedulers.mainThread())
    .compose(bindUntil(BindState.UNBOUND))
    .compose(view().bindUntil(ActivityState.DESTROYED))
    .subscribe(event -> {
        Log.i(TAG, "fetchPoints");
        fetchUserPoints();
    }, Throwable::printStackTrace);