Easy Backpressure

Limit Consumption Rate

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.

Expected

Requested: 5

Previous Next

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

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.

Expected

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