Skip to content

Commit f1b9253

Browse files
Merge pull request ReactiveX#1964 from zsxwing/fix-buffer-request
Handle 0 or negative request in Buffer
2 parents 73715bf + 0c135fd commit f1b9253

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -144,6 +144,12 @@ private void requestInfinite() {
144144

145145
@Override
146146
public void request(long n) {
147+
if (n == 0) {
148+
return;
149+
}
150+
if (n < 0) {
151+
throw new IllegalArgumentException("request a negative number: " + n);
152+
}
147153
if (infinite) {
148154
return;
149155
}

0 commit comments

Comments
 (0)