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

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

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. Здесь вы можете найти образец проекта – RxJava2-Android-Samples

Это то, что говорится в документах

Практически, 1.x fromEmitter (ранее fromAsync) был переименован в Flowable.create. Другие базовые реактивные типы имеют аналогичные методы создания (за вычетом стратегии противодавления).

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

Документация Rx.2