How to use Flowable in RxJava 2?

Question

RxJava2 has a new Flowable. How to use this in android. There was no Flowable in 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()); } }; } } 

I have a sample project to demonstrate the use of RxJava2. Here you can find a sample project - RxJava2-Android-Samples

Answer 2

This is what he says in the docs

In practice, 1.x fromEmitter (formerly from Async) has been renamed to Flowable.create. Other basic reactive types are similar (minus the backpressure strategy).

So you can use this the same way as fromEmitter and fromAsync

Rx.2 Documentation