Fix MonoProcessor#block duration.zero change

reactor · May 7, 2019 · c995c01 · c995c01
1 parent 2992d21
commit c995c01
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/MonoProcessor.java b/reactor-core/src/main/java/reactor/core/publisher/MonoProcessor.java
@@ -178,13 +178,6 @@ public O block(@Nullable Duration timeout) {
 				delay = System.nanoTime() + timeout.toNanos();
 			}
 			for (; ; ) {
-				if (timeout != null && delay < System.nanoTime()) {
-					cancel();
-					throw new IllegalStateException("Timeout on Mono blocking read");
-				}
-
-				Thread.sleep(1);
-
 				NextInner<O>[] inners = subscribers;
 				if (inners == TERMINATED) {
 					if (error != null) {
@@ -197,6 +190,12 @@ public O block(@Nullable Duration timeout) {
 					}
 					return value;
 				}
+				if (timeout != null && delay < System.nanoTime()) {
+					cancel();
+					throw new IllegalStateException("Timeout on Mono blocking read");
+				}
+
+				Thread.sleep(1);
 			}
 
 		}