RxJava 2 में फ़्लोएबल का उपयोग कैसे करें?

Question

RxJava2 में नए फ़्लोएबल का परिचय है। एंड्रॉइड में इसका उपयोग कैसे करें। RxJava1 में कोई फ़्लोबल नहीं था।

Answer 1

public class FlowableExampleActivity extends AppCompatActivity { 

    private static final String TAG = FlowableExampleActivity.class.getSimpleName(); 
    Button btn; 
    TextView textView; 

    @Override 
    protected void onCreate(Bundle savedInstanceState) { 
     super.onCreate(savedInstanceState); 
     setContentView(R.layout.activity_example); 
     btn = (Button) findViewById(R.id.btn); 
     textView = (TextView) findViewById(R.id.textView); 

     btn.setOnClickListener(new View.OnClickListener() { 
      @Override 
      public void onClick(View view) { 
       doSomeWork(); 
      } 
     }); 
    } 

    /* 
    * simple example using Flowable 
    */ 
    private void doSomeWork() { 

     Flowable<Integer> observable = Flowable.just(1, 2, 3, 4); 

     observable.reduce(50, new BiFunction<Integer, Integer, Integer>() { 
      @Override 
      public Integer apply(Integer t1, Integer t2) { 
       return t1 + t2; 
      } 
     }).subscribe(getObserver()); 

    } 

    private SingleObserver<Integer> getObserver() { 

    return new SingleObserver<Integer>() { 
     @Override 
     public void onSubscribe(Disposable d) { 
      Log.d(TAG, " onSubscribe : " + d.isDisposed()); 
     } 

     @Override 
     public void onSuccess(Integer value) { 
      Log.d(TAG, " onSuccess : value : " + value); 
     } 

     @Override 
     public void onError(Throwable e) { 
      Log.d(TAG, " onError : " + e.getMessage()); 
     } 
    }; 
} 
} 

मेरे पास RxJava2 के उपयोग को प्रदर्शित करने के लिए नमूना प्रोजेक्ट तैयार किया गया है। यहाँ आप sample project - RxJava2-Android-Samples

Answer 2

पा सकते हैं यह वही है दस्तावेजों

व्यावहारिक रूप से, 1.x fromEmitter (पूर्व fromAsync) Flowable.create को नाम दिया गया है में कहते है। अन्य आधार प्रतिक्रियाशील प्रकारों के समान विधियों (बैकप्रेसर रणनीति से कम) बनाते हैं।

तो तुम fromEmitter के रूप में एक ही तरीके से इसका उपयोग कर सकते हैं और fromAsync

Rx.2 Documentation