Skip to content

Instantly share code, notes, and snippets.

@abdallahalaraby
abdallahalaraby / RxBus2.java
Created November 2, 2017 12:07
An event bus implementation that uses RxJava2
import io.reactivex.Observable;
import io.reactivex.subjects.PublishSubject;
public class RxBus {
private static volatile RxBus sRxBus = null;
private PublishSubject<Object> mPublishSubject = PublishSubject.create();
private RxBus() {
}