Czym jest backpressure w strumieniach?

Backpressure w strumieniach to mechanizm kontroli przepływu danych, który zapobiega przepełnieniu bufora, gdy produkcja danych jest zbyt szybka w porównaniu do ich konsumowania.

Gdy źródło danych (producent) generuje dane szybciej, niż jest w stanie je przetworzyć konsument (odbiorca), istnieje ryzyko przepełnienia pamięci lub utraty danych. Backpressure pozwala konsumentowi sygnalizować źródłu konieczność zwolnienia tempa przesyłania danych lub tymczasowego wstrzymania.

Na przykład w Node.js, metoda stream.pause() i zdarzenie drain są używane do implementacji backpressure, aby zrównoważyć prędkość odczytu i zapisu danych.