makes throwable assignment HB done assignment in onError (#3638)

Signed-off-by: Oleh Dokuka <[email protected]>
reactor · Nov 13, 2023 · 9e9649c · 9e9649c
1 parent 24bea93
commit 9e9649c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/reactor-core/src/main/java/reactor/core/publisher/FluxPublish.java b/reactor-core/src/main/java/reactor/core/publisher/FluxPublish.java
@@ -316,11 +316,13 @@ public void onError(Throwable t) {
 				return;
 			}
 
-			done = true;
 			if (!Exceptions.addThrowable(ERROR, this, t)) {
 				Operators.onErrorDroppedMulticast(t, subscribers);
+				return;
 			}
 
+			done = true;
+
 			long previousState = markTerminated(this);
 			if (isTerminated(previousState) || isCancelled(previousState)) {
 				return;