Easy Backpressure

Limit Consumption Rate

Traducción al español en progresoEl contenido detallado de esta lección aún se está traduciendo. Mientras tanto, se muestra en inglés.

Create a Flux emitting 1 through 20 and use limitRate(5) to request items in batches of 5. Use doOnRequest to print how many items are requested at each batch. Subscribe and print each value.

limitRate(n) prefetches n items at a time, implementing backpressure.

Esperado

Requested: 5

Anterior Siguiente

Main.kt

Limit Consumption Rate

easy⏱ 15 minkotlinreactorchallengebackpressure

Create a Flux emitting 1 through 20 and use limitRate(5) to request items in batches of 5. Use doOnRequest to print how many items are requested at each batch. Subscribe and print each value.

limitRate(n) prefetches n items at a time, implementing backpressure.

Why this works

limitRate(n) implements backpressure by limiting the prefetch amount. The downstream requests n items at a time rather than unbounded. doOnRequest is a side-effect operator that logs how many items are being requested.

Expected output

Requested: 5

Limit Consumption Rate

Traducción al español en progresoEl contenido detallado de esta lección aún se está traduciendo. Mientras tanto, se muestra en inglés.

Create a Flux emitting 1 through 20 and use limitRate(5) to request items in batches of 5. Use doOnRequest to print how many items are requested at each batch. Subscribe and print each value.

limitRate(n) prefetches n items at a time, implementing backpressure.

Esperado

Requested: 5

Limit Consumption Rate

easy⏱ 15 minkotlinreactorchallengebackpressure

Create a Flux emitting 1 through 20 and use limitRate(5) to request items in batches of 5. Use doOnRequest to print how many items are requested at each batch. Subscribe and print each value.

limitRate(n) prefetches n items at a time, implementing backpressure.

Why this works

Expected output

Requested: 5