Medium Backpressure

Sample Latest Values

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 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.

Esperado

1
2
3
Cancelled!

Anterior Siguiente

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

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 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.

Esperado

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!