diff --git a/src/main/java/rx/internal/operators/OperatorBufferWithSize.java b/src/main/java/rx/internal/operators/OperatorBufferWithSize.java index 6f14f4bbf7..60872b5ba7 100644 --- a/src/main/java/rx/internal/operators/OperatorBufferWithSize.java +++ b/src/main/java/rx/internal/operators/OperatorBufferWithSize.java @@ -144,6 +144,12 @@ private void requestInfinite() { @Override public void request(long n) { + if (n == 0) { + return; + } + if (n < 0) { + throw new IllegalArgumentException("request a negative number: " + n); + } if (infinite) { return; }