Medium Error Handling

Retry on Failure

Create a Flux using Flux.defer() with a counter. On the first 2 calls, emit an error. On the 3rd call, emit "Success!". Use retry(2) to automatically retry. Print the output.

retry(n) re-subscribes to the upstream up to n times on error.

Expected

Success!

Previous Next

Main.kt

Retry on Failure

medium⏱ 15 minkotlinreactorchallengeerror-handling

Create a Flux using Flux.defer() with a counter. On the first 2 calls, emit an error. On the 3rd call, emit "Success!". Use retry(2) to automatically retry. Print the output.

retry(n) re-subscribes to the upstream up to n times on error.

Why this works

retry(n) re-subscribes to the upstream Publisher up to n times when an error occurs. Flux.defer/Mono.defer creates the publisher lazily so each retry gets a fresh evaluation.

Expected output

Success!

Reactor Challenges/Error Handling

Medium Error Handling

Retry on Failure

Create a Flux using Flux.defer() with a counter. On the first 2 calls, emit an error. On the 3rd call, emit "Success!". Use retry(2) to automatically retry. Print the output.

retry(n) re-subscribes to the upstream up to n times on error.

Expected

Success!

Previous Next

Main.kt

Retry on Failure

medium⏱ 15 minkotlinreactorchallengeerror-handling

Create a Flux using Flux.defer() with a counter. On the first 2 calls, emit an error. On the 3rd call, emit "Success!". Use retry(2) to automatically retry. Print the output.

retry(n) re-subscribes to the upstream up to n times on error.

Why this works

retry(n) re-subscribes to the upstream Publisher up to n times when an error occurs. Flux.defer/Mono.defer creates the publisher lazily so each retry gets a fresh evaluation.

Expected output

Success!