2017-01-08 5 views
4

Singles、Maybes、Completablesをマルチキャストするにはどうすればよいですか?それらをマルチキャストするために標準Observableに変換することをお勧めしますか?RxJava2 - メジャーリーグ、メイベス、コンプリート?

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(); 

私は少しConnectableSingleConnectableMaybe、およびConnectableCompletable決してありません驚いています。これの背後にある理由は何ですか?それは開発するだけの価値がないのでしょうか?

+3

それぞれには 'cache()'演算子があり、2.0.5には 'Subject'変形があります。接続可能なバージョンは必要ありませんでした。私はそれらがまったく必要ではないと感じています。あなたがタイプ間を歩くことができるので、あなたが示したようにこれを回避することができます。 – akarnokd

答えて

0

だと思いますが、.toObservable().publish()は行く方法です。

関連する問題