Skip to content

Commit 7ba2636

Browse files
davidmotenbenjchristensen
authored andcommitted
OperatorScan should check for MAX_VALUE on request
1 parent 46b5a0f commit 7ba2636

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ public void setProducer(final Producer producer) {
129129
@Override
130130
public void request(long n) {
131131
if (once.compareAndSet(false, true)) {
132-
if (initialValue == NO_INITIAL_VALUE) {
132+
if (initialValue == NO_INITIAL_VALUE || n == Long.MAX_VALUE) {
133133
producer.request(n);
134134
} else {
135135
producer.request(n - 1);

0 commit comments

Comments
 (0)