Sistem və ya tətbiqdə backpressure mexanizmi ilə qarşılaşdığınız vəziyyəti təsvir edin.

Backpressure — bu mexanizmdir məlumat axını idarə etmək üçün, bu mexanizm istehlakçının daxil olan məlumatları eyni sürətlə işləyə bilmədiyi halda aşırı yüklənmənin qarşısını alır.

Məsələn, Android-də RxJava ilə, əgər Observable hadisələri Subscriber onları işləyə biləcəkdən daha sürətlə yaradırsa, backpressure baş verir. Düzgün idarə olunmazsa, bu OutOfMemoryError və ya tətbiqin çökməsinə səbəb ola bilər.

Bunu idarə etmək üçün, RxJava operatorlarından istifadə etmək olar, məsələn, onBackpressureBuffer(), onBackpressureDrop() və ya onBackpressureLatest(), hansı ki, məlumat axınını tənzimləyir, elementləri tamponlayır və ya atır.

Nümunə:

Observable.interval(1, TimeUnit.MILLISECONDS)
    .onBackpressureBuffer() // abunəçi yetişmədikdə elementləri tamponlayır
    .observeOn(Schedulers.computation())
    .subscribe { item ->
        Thread.sleep(10) // yavaş işləmə
        println(item)
    }

Bu nümunədə, onBackpressureBuffer() olmadan, axın çox sürətli olacaq və səhvlərə səbəb olacaq.