2017-01-08 4 views
4

Каков рекомендуемый способ для многоадресной рассылки одиночных игр, майбы и полные таблицы? Рекомендуется ли просто превращать их в стандартные Observables для многоадресной рассылки?RxJava2 - Mutlicasting Singles, Maybes и Completables?

Observable<String> strings = 
      Observable.just("Alpha", "Beta", "Gamma", "Delta", "Epsilon"); 

    Observable<Integer> lengths = strings.map(String::length); 

    ConnectableObservable<List<Integer>> lengthsList = 
      lengths.toList().toObservable().publish(); 

Я немного удивлен, что нет ConnectableSingle, ConnectableMaybe и ConnectableCompletable. Каковы причины этого? Разве это не стоит усилий для развития?

+3

У каждого есть оператор 'cache()', а 2.0.5 будет иметь вариант «Subject». Не было необходимости в подключаемых версиях, и я не чувствую, что они нужны вообще. Поскольку вы можете ходить между типами, вы можете обойти это, как вы показали. – akarnokd

ответ

0

Думаю, .toObservable().publish() - это путь.

Смежные вопросы