Aprakstiet situāciju, kad saskaraties ar backpressure mehānismu sistēmā vai lietojumprogrammā.

Backpressure — tas ir datu plūsmas pārvaldības mehānisms, kas novērš pārslodzi, ja patērētājs nespēj apstrādāt ienākošos datus ar tādu pašu ātrumu, kādā tie ienāk.

Piemēram, Android ar RxJava, ja Observable ģenerē notikumus ātrāk nekā Subscriber tos var apstrādāt, rodas backpressure. Bez pareizas pārvaldības tas var novest pie OutOfMemoryError vai lietotnes avārijas.

Lai ar to tiktu galā, var izmantot RxJava operatorus kā onBackpressureBuffer(), onBackpressureDrop() vai onBackpressureLatest(), kas regulē datu plūsmu, buferējot vai atmetot pārpalikušos elementus.

Piemērs:

Observable.interval(1, TimeUnit.MILLISECONDS)
    .onBackpressureBuffer() // buferē elementus, ja abonents nevar sekot līdzi
    .observeOn(Schedulers.computation())
    .subscribe { item ->
        Thread.sleep(10) // lēna apstrāde
        println(item)
    }

Bez onBackpressureBuffer(), plūsma būs pārāk ātra apstrādei, kas radīs kļūdas.