RXjavaのトランスフォームのタイプ

Question

シングルからシングルへのようなオブザーバブルを変換することは可能ですか？オペレータcompose（）がこの目的のために使用されていると思いますが、実装方法が分かりません。

私がここで達成したいことは、次のコードスニペットでより明確に理解できます。

@Override 
public Single<SystemDefaults> getSystemDefaults() { 

    SystemDefaults systemDefaults = new SystemDefaults(); 
    return systemDao.getRoles().compose((SingleTransformer<List<Role>, SystemDefaults>) upstream -> { 
     //WHAT SHOULD I DO HERE? 
    }); 

} 

私はRxJava（Android）にはかなり新しく、ここでかなり失われています。

Answer 1

オペレータmapが必要です。 Mapは（など、またはSingle秒Maybe s）はあなたのObservableのすべてのアイテムを取り、別の値に変換：

Observable.just(1)          // Start emitting Integers 
       .map(number -> number.toString()})  // Transform it to String 
       .subscribe(someString -> System.out.println(someString.getClass()));  // Receive an String 

Answer 2

はいオペレータはあなたが作ったものを探していて、以前の観測可能な/単一から観測可能な/単一のものを変換するために使用されます。

ここでは、Integer observableをString observableに変換する例を示します。

Observable.Transformer<Integer, String> transformIntegerToString() { 
     return observable -> observable.map(String::valueOf); 
    } 

    /** 
    * In this example we use a transformer to get the Integer item emitted and transform to String 
    */ 
    @Test 
    public void observableWithTransformToString() { 
     Observable.just(1) 
        .map(number -> { 
         System.out.println("Item is Integer:" + Integer.class.isInstance(number)); 
         return number; 
        }) 
        .compose(transformIntegerToString()) 
        .subscribe(number -> System.out.println("Item is String:" + (String.class.isInstance(number)))); 

    } 

あなたがここに別のスレッドで別の観測可能にそれを変更する方法を別の例を見ることができます。 https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/transforming/ObservableCompose.java