Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: ReactiveX/RxJava
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: 3.x
Choose a base ref
...
head repository: ReactiveX/RxJava
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: MpscLinkedQueueFix2
Choose a head ref
Able to merge. These branches can be automatically merged.
  • 1 commit
  • 1 file changed
  • 1 contributor

Commits on Nov 26, 2024

  1. Fix a possible issue introduced with #7799

    @akarnokd
    akarnokd committed Nov 26, 2024
    Loading
    Loading status checks…
    Copy the full SHA
    2520d7f View commit details
Showing with 2 additions and 2 deletions.
  1. +2 −2 src/main/java/io/reactivex/rxjava3/internal/queue/MpscLinkedQueue.java
4 changes: 2 additions & 2 deletions src/main/java/io/reactivex/rxjava3/internal/queue/MpscLinkedQueue.java
View file
Original file line number Diff line number Diff line change
@@ -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;