1 package ordertracker;
2
3 import rx.Observable;
4 import rx.subjects.PublishSubject;
5
6 public class EventService {
7
8 private static EventServiceEventService instance = new EventService();
9
10 private final PublishSubject<String> subject = PublishSubject.create();
11
12 public static EventService instance() {
13 return instance;
14 }
15
16 public void event(String data) {
17 subject.onNext(data);
18 }
19
20 public Observable<String> events() {
21 return subject.serialize().asObservable();
22 }
23
24 }