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) {
_bus.onNext(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