gistfile1.txt

import java.util.*;
 
import rx.*;
import rx.subjects.*;
 
 
public class RxEventBus<T> {
    private final Subject<Notification<T>, Notification<T>> subject;
    public RxEventBus() {
        subject = PublishSubject.<Notification<T>>create().toSerialized();
    }
    public void post(T value) {
        subject.onNext(Notification.createOnNext(value));
    }
    public void postError(Throwable e) {
        subject.onNext(Notification.createOnError(e));
    }
    public Observable<Notification<T>> observe() {
        return subject;
    }
}