Skip to content

Commit 775248c

Browse files
committed
add error message to ProducerArbiter
1 parent a900541 commit 775248c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/rx/internal/producers/ProducerArbiter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ public void produced(long n) {
9595
if (r != Long.MAX_VALUE) {
9696
long u = r - n;
9797
if (u < 0) {
98-
throw new IllegalStateException();
98+
throw new IllegalStateException("more items arrived than were requested");
9999
}
100100
requested = u;
101101
}

0 commit comments

Comments
 (0)