Medium Backpressure

Sample Latest Values

Create a Flux emitting 1 through 10, then use take(3) to only consume the first 3 elements (simulating a slow consumer). Subscribe and print.

take(n) cancels the subscription after receiving n elements — a simple form of backpressure.

Expected

1
2
3
Cancelled!

Previous Next

Main.kt

Sample Latest Values

medium⏱ 15 minkotlinreactorchallengebackpressure

Create a Flux emitting 1 through 10, then use take(3) to only consume the first 3 elements (simulating a slow consumer). Subscribe and print.

take(n) cancels the subscription after receiving n elements — a simple form of backpressure.

Why this works

take(n) requests only n elements from upstream and then cancels the subscription. doOnCancel() lets you observe when a cancellation happens, which is useful for debugging backpressure behavior.

Expected output

1
2
3
Cancelled!

Sample Latest Values

Create a Flux emitting 1 through 10, then use take(3) to only consume the first 3 elements (simulating a slow consumer). Subscribe and print.

take(n) cancels the subscription after receiving n elements — a simple form of backpressure.

Expected

1 2 3 Cancelled!

Sample Latest Values

medium⏱ 15 minkotlinreactorchallengebackpressure

Create a Flux emitting 1 through 10, then use take(3) to only consume the first 3 elements (simulating a slow consumer). Subscribe and print.

take(n) cancels the subscription after receiving n elements — a simple form of backpressure.

Why this works

take(n) requests only n elements from upstream and then cancels the subscription. doOnCancel() lets you observe when a cancellation happens, which is useful for debugging backpressure behavior.

Expected output

1 2 3 Cancelled!