دوره زبان تخصصی برای برنامه‌نویسان (هدیه ویژه ثبت‌نام در دوره‌های متخصص) (فرصت محدود ⏰)
۰ ثانیه
۰ دقیقه
۰ ساعت
۰ Ali Rah
استفاده از backpressure در observable‌های از نوع cold?
جامعه جاوا (اندروید) ایجاد شده در ۲۰ آبان ۱۴۰۱

از آنجایی که در 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
                }
            });