Issue ReactiveX#212: Added test to FluxCircuitBreakerTest to verify that an error is propagated when you subscribe to Flux.error, but the error is not thrown onSubscribe.

Author: Robert Winkler

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

@@ -48,6 +48,17 @@ public void shouldPropagateError() {
         assertSingleFailedCall();
     }
 
+    @Test
+    public void shouldPropagateErrorWhenErrorNotOnSubscribe() {
+        StepVerifier.create(
+                Flux.error(new IOException("BAM!"), true)
+                        .transform(CircuitBreakerOperator.of(circuitBreaker)))
+                .expectError(IOException.class)
+                .verify(Duration.ofSeconds(1));
+
+        assertSingleFailedCall();
+    }
+
     @Test
     public void shouldEmitErrorWithCircuitBreakerOpenException() {
         circuitBreaker.transitionToOpenState();