gistfile1.txt

@Test
    public void fluxErrorHandling_withRetry(){

        Flux<String> stringFlux = Flux.just("a","b","c")
                .concatWith(Flux.error(new RuntimeException("Exception Occurred")))
                .concatWith(Flux.just("D"))
                .onErrorMap((e) -> new CustomException(e))
                .retry(2);

        // P.s. Retry produces same stream again

        StepVerifier.create(stringFlux.log())
                .expectSubscription()
                .expectNext("a","b","c")
                .expectNext("a","b","c")
                .expectNext("a","b","c")
                .expectError(CustomException.class)
                .verify();
    }