From 0c135fdabfde4a0b70c1ddd238f64263344215b0 Mon Sep 17 00:00:00 2001 From: zsxwing Date: Fri, 12 Dec 2014 22:39:26 +0800 Subject: [PATCH] Handle 0 or negative request in Buffer --- .../java/rx/internal/operators/OperatorBufferWithSize.java | 6 ++++++ 1 file changed, 6 insertions(+) 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; }