Create a gist now

Instantly share code, notes, and snippets.

What would you like to do?
Blog post snippet for implementing event bus
// this is the middleman object
public class RxBus {
private final Subject<Object, Object> _bus = new SerializedSubject<>(PublishSubject.create());
public void send(Object o) {
public Observable<Object> toObserverable() {
return _bus;
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment