RetroSearch Browse

Showing content from https://github.com/ReactiveX/RxJava/commit/ede5cfcb41a6a1c8f955d77d80883d5d08e843d9 below:

File tree Expand file treeCollapse file tree 1 file changed

-0

lines changed

Filter options

Expand file treeCollapse file tree 1 file changed

-0

lines changed Original file line number Diff line number Diff line change


 @@ -91,6 +91,8 @@ public T poll() {

91 91


 // we have to null out the value because we are going to hang on to the node

92 92


 final T nextValue = nextNode.getAndNullValue();

93 93


 spConsumerNode(nextNode);

94

+
 // unlink previous consumer to help gc

95

+
 currConsumerNode.soNext(null);

94 96


 return nextValue;

95 97

96 98


 else if (currConsumerNode != lvProducerNode()) {


 @@ -101,6 +103,8 @@ else if (currConsumerNode != lvProducerNode()) {

101 103


 // we have to null out the value because we are going to hang on to the node

102 104


 final T nextValue = nextNode.getAndNullValue();

103 105


 spConsumerNode(nextNode);

106

+
 // unlink previous consumer to help gc

107

+
 currConsumerNode.soNext(null);

104 108


 return nextValue;

105 109

106 110


 return null;

You can’t perform that action at this time.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4