Skip to content

Commit 047cc28

Browse files
committed
Added value null check
1 parent 34bf40a commit 047cc28

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/rx/internal/operators/OperatorOnBackpressureBuffer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ public Object peek() {
126126
@Override
127127
public Object poll() {
128128
Object value = queue.poll();
129-
if (capacity != null) {
129+
if (capacity != null && value != null) {
130130
capacity.incrementAndGet();
131131
}
132132
return value;

0 commit comments

Comments
 (0)