Medium Backpressure

Buffer Elements

Create a Flux emitting 1 through 12 and use buffer(4) to collect elements in batches of 4. Subscribe and print each batch.

buffer(n) collects n elements into a List before emitting the batch downstream.

Expected

[1, 2, 3, 4]
[5, 6, 7, 8]
[9, 10, 11, 12]

Previous Next

Main.kt

Buffer Elements

medium⏱ 15 minkotlinreactorchallengebackpressure

Create a Flux emitting 1 through 12 and use buffer(4) to collect elements in batches of 4. Subscribe and print each batch.

buffer(n) collects n elements into a List before emitting the batch downstream.

Why this works

buffer(n) collects n elements into a List<T> before emitting the list downstream. This is a common backpressure strategy where you process elements in fixed-size batches.

Expected output

[1, 2, 3, 4]
[5, 6, 7, 8]
[9, 10, 11, 12]

Reactor Challenges/Backpressure

Medium Backpressure

Buffer Elements

Create a Flux emitting 1 through 12 and use buffer(4) to collect elements in batches of 4. Subscribe and print each batch.

buffer(n) collects n elements into a List before emitting the batch downstream.

Expected

[1, 2, 3, 4]
[5, 6, 7, 8]
[9, 10, 11, 12]

Previous Next

Main.kt

Buffer Elements

medium⏱ 15 minkotlinreactorchallengebackpressure

Create a Flux emitting 1 through 12 and use buffer(4) to collect elements in batches of 4. Subscribe and print each batch.

buffer(n) collects n elements into a List before emitting the batch downstream.

Why this works

buffer(n) collects n elements into a List<T> before emitting the list downstream. This is a common backpressure strategy where you process elements in fixed-size batches.

Expected output

[1, 2, 3, 4]
[5, 6, 7, 8]
[9, 10, 11, 12]