Как использовать Flowable в RxJava 2?

Question

В RxJava2 появилось новое Flowable. Как использовать это в android. В RxJava1 не было Flowable.

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. Другие базовые реактивные типы имеют аналогичные методы создания (минус стратегия противодавления).

Таким образом, вы можете использовать это таким же образом, как и fromEmitterfromAsync

Rx.2 Documentation