Reusable Transform Pipeline

Create a reusable transform function called `addLogging` that takes a Flux<String> and returns a Flux<String> that:

1. Adds a doOnNext printing "Processing: <item>"

2. Maps each item to uppercase

Apply it to a Flux of "hello", "world", "reactor" using .transform(). Print results.

transform() applies a reusable pipeline of operators.

Expected

Processing: hello
HELLO
Processing: world
WORLD
Processing: reactor
REACTOR

Main.kt

Reusable Transform Pipeline

hard⏱ 15 minkotlinreactorchallengeadvanced-patterns

Create a reusable transform function called addLogging that takes a Flux<String> and returns a Flux<String> that:

Adds a doOnNext printing "Processing: <item>"
Maps each item to uppercase

Apply it to a Flux of "hello", "world", "reactor" using .transform(). Print results.

transform() applies a reusable pipeline of operators.

Why this works

transform() applies a Function<Flux<T>, Flux<R>> to a Flux, enabling reusable operator pipelines. This promotes DRY code by encapsulating common operator chains that can be applied to different sources.

Expected output

Processing: hello
HELLO
Processing: world
WORLD
Processing: reactor
REACTOR

Reusable Transform Pipeline

Create a reusable transform function called `addLogging` that takes a Flux<String> and returns a Flux<String> that:

1. Adds a doOnNext printing "Processing: <item>"

2. Maps each item to uppercase

Apply it to a Flux of "hello", "world", "reactor" using .transform(). Print results.

transform() applies a reusable pipeline of operators.

Expected

Processing: hello HELLO Processing: world WORLD Processing: reactor REACTOR

Reusable Transform Pipeline

hard⏱ 15 minkotlinreactorchallengeadvanced-patterns

Create a reusable transform function called addLogging that takes a Flux<String> and returns a Flux<String> that:

Adds a doOnNext printing "Processing: <item>"

Maps each item to uppercase

Apply it to a Flux of "hello", "world", "reactor" using .transform(). Print results.

transform() applies a reusable pipeline of operators.

Why this works

Expected output

Processing: hello HELLO Processing: world WORLD Processing: reactor REACTOR