Fix a possible issue introduced with #7799

ReactiveX · Nov 26, 2024 · 2520d7f · 2520d7f
1 parent ede5cfc
commit 2520d7f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/io/reactivex/rxjava3/internal/queue/MpscLinkedQueue.java b/src/main/java/io/reactivex/rxjava3/internal/queue/MpscLinkedQueue.java
@@ -92,7 +92,7 @@ public T poll() {
             final T nextValue = nextNode.getAndNullValue();
             spConsumerNode(nextNode);
             // unlink previous consumer to help gc
-            currConsumerNode.soNext(null);
+            currConsumerNode.soNext(currConsumerNode);
             return nextValue;
         }
         else if (currConsumerNode != lvProducerNode()) {
@@ -104,7 +104,7 @@ else if (currConsumerNode != lvProducerNode()) {
             final T nextValue = nextNode.getAndNullValue();
             spConsumerNode(nextNode);
             // unlink previous consumer to help gc
-            currConsumerNode.soNext(null);
+            currConsumerNode.soNext(currConsumerNode);
             return nextValue;
         }
         return null;