Skip to content

Instantly share code, notes, and snippets.

View SaeedMasoumi's full-sized avatar
🎯
Focusing

Saeed Masoumi SaeedMasoumi

🎯
Focusing
View GitHub Profile
import rx.Observable;
import rx.subjects.PublishSubject;
import rx.subjects.SerializedSubject;
import rx.subjects.Subject;
/**
* Simple pass-thru event bus with error handling and reconnect.
*/
public class EventBus {