RxJava и случайные спорадические события на Android

Question

Я хочу использовать RxJava, как я бы использовал EventBus Guava или Otto, но я не вижу, как я могу заставить его функционировать таким образом.

Это сценарий: допустим, у меня есть кнопка в приложении для Android, и каждый раз, когда нажимается кнопка, я хочу, чтобы RxJava излучал событие через мой Observable. Мне кажется, что я должен получить услугу reregister после того, как она получит событие, и что для этой деятельности потребуется создать и новую наблюдаемую.

Как, если я скажу

Observable.from(x) 

мне кажется, я должен был бы, что для каждого события, но создает новый наблюдаемым, что нужно будет регистрироваться снова. Конечно, я чего-то не хватает.

Answer 1

Вы можете сделать что-то вроде этого (от rx.subjects.PublishSubject):

PublishSubject<Object> subject = PublishSubject.create(); 
// observer1 will receive all onNext and onCompleted events 
subject.subscribe(observer1); 
subject.onNext("one"); 
subject.onNext("two"); 
// observer2 will only receive "three" and onCompleted 
subject.subscribe(observer2); 
subject.onNext("three"); 
subject.onCompleted(); 

Если вы могли бы внедрить интерфейс Subject в Службу и PublishSubject в операцию (или наоборот в зависимости от что вы делаете), вы можете иметь хорошее разделение проблем.

Answer 2

The newly added refCount operator for ConnectableObservable being added in 0.14.3 также будет полезен вам для использования в этом типе использования.

Он поддерживает автоматическое соединение/разъединение, когда множество наблюдателей приходят и уходят.