Event.java

package io.github.hkusu.sample.android.lib.rx;

import rx.Observable;
import rx.subjects.PublishSubject;
import rx.subjects.SerializedSubject;
import rx.subjects.Subject;

public class Event<T> {
    private final Subject<T, T> subject = new SerializedSubject<>(PublishSubject.create());

    public Observable<T> observable() {
        return subject;
    }

    public void post(T t) {
        subject.onNext(t);
    }
}