Issue ReactiveX#212: Added test to FluxCircuitBreakerTest to verify that a CircuitBreakerException is thrown when you subscribe to Flux.error.

Author: Robert Winkler

README.adoc

@@ -28,6 +28,9 @@ Core modules:
 
 Add-on modules
 
+* resilience4j-reactor: Spring Reactor adapter
+* resilience4j-rxjava2: RxJava2 adapter
+* resilience4j-micrometer: Micrometer Metrics exporter
 * resilience4j-metrics: Dropwizard Metrics exporter
 * resilience4j-prometheus: Prometheus Metrics exporter
 * resilience4j-spring-boot: Spring Boot Starter

resilience4j-reactor/src/test/java/io/github/resilience4j/reactor/circuitbreaker/operator/FluxCircuitBreakerTest.java

@@ -60,6 +60,18 @@ public void shouldEmitErrorWithCircuitBreakerOpenException() {
         assertNoRegisteredCall();
     }
 
+    @Test
+    public void shouldEmitCircuitBreakerOpenExceptionEvenWhenErrorNotOnSubscribe() {
+        circuitBreaker.transitionToOpenState();
+        StepVerifier.create(
+                Flux.error(new IOException("BAM!"), true)
+                        .transform(CircuitBreakerOperator.of(circuitBreaker)))
+                .expectError(CircuitBreakerOpenException.class)
+                .verify(Duration.ofSeconds(1));
+
+        assertNoRegisteredCall();
+    }
+
     @Test
     public void shouldEmitCircuitBreakerOpenExceptionEvenWhenErrorDuringSubscribe() {
         circuitBreaker.transitionToOpenState();