از آنجایی که در Observableهای از نوع Hot از backpressure strategy باید استفاده بشه پس چرا در مثال زیر که از نوع Cold هست باید از backpressure استفاده کرد تا برنامه crash نکنه؟
Flowable.interval(1, TimeUnit.MILLISECONDS, Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer() {
@Override
public void accept(Long aLong) throws Exception {
// do smth
}
});