În care dintre fluxurile de procesare a datelor este implementată mecanica de gestionare a încărcăturii (backpressure)?

Mecanismul de control al presiunii (backpressure) este implementat pe partea consumatorului (abonat) în fluxul de procesare a datelor. Aceasta înseamnă că consumatorul controlează câte date este dispus să accepte și să proceseze, pentru a nu se supraîncărca pe sine și sistemul.

În fluxurile reactive (de exemplu, RxJava, Flow în Kotlin), abonatul solicită un anumit număr de elemente de la sursă, iar sursa nu trimite mai mult decât s-a solicitat. Astfel, se atinge un echilibru între producător și consumator, prevenind supraîncărcarea bufferelor și OutOfMemory.

Exemplu în RxJava:

Flowable.range(1, 1000)
    .onBackpressureBuffer()
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onSubscribe(Subscription s) {
            s.request(10); // solicită 10 elemente
        }

        @Override
        public void onNext(Integer integer) {
            // procesarea elementului
        }

        // alte metode...
    });

Prin urmare, backpressure este un mecanism încorporat în fluxul de date, unde consumatorul controlează viteza de sosire a datelor.