Из личного опыта советую использовать RxJava
. Все рано или поздно к ней приходят, хотя бы что-то попробовать. Одно из преимуществ то, что Вы можете работать без подписок отписок просто с синглтон классом. И если вы используете "реактивный подход" в целом, то уже нет надобности подключать дополнительную стороннюю библиотеку.
Стоит отметить, что в RxJava1
и в RxJava2
реализация изменилась в плане используемых классов. В случае первой версии использовался интерфейс Action1<T>
, который во второй заменили на Consumer<T>
. Так как первые гайды на которые Вы можете наткнуться с большой вероятностю будут описывать первую версию это поможем решить проблему.
Пример передачи событий используя RxJava 2
Singletone-класс
public class RxBus {
private static RxBus instance;
private PublishSubject<String> messages = PublishSubject.create();
public static RxBus instanceOf() {
if (instance == null) {
instance = new RxBus();
}
return instance;
}
public void setString(String object) {
messages.onNext(object);
}
public Observable<String> getMessages() {
return messages;
}
}
Вызов экзепляра:
RxBus bus = RxBus.instanceOf();
Отправка события:
bus.setString("example");
Прием события:
bus.getMessages().subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
switch (s){
case "example":
System.out.println("hello world");
}
}
});
Следует отметить, что если вы транслируете одно и тоже событие (в данном примере если передавать один и тот же String
), то все живые компоненты которые на него подписаны будут его получать. Например, если у Вас есть 2 живые активности, которые отлавливают такое событие и в результате получения создают и переходят на третью активность, то последняя у вас создастся в двух экземплярах.
Учитывая этот факт Вы должны либо сразу работать с уникальными событиями, либо дополнять RxBus
соответственным методом unsubscribe()
.
deprecated
, поэтому я бы не стал ее сравнивать. Вот немного информации.goto
.