if (!s.isOnNext()
|| r < 0 || r == Long.MAX_VALUE //was Long.MAX from beginning or switched to unbounded
|| r >= produced) {
return false;
}
<BUG>else {
setFailure(null, s, "expected production of at most %s; produced: %s; request overflown by signal: %s",

r, produced, s);</BUG>
return true;

if (!s.isOnNext()
|| r < 0 || r == Long.MAX_VALUE //was Long.MAX from beginning or switched to unbounded
|| r >= produced) {
return false;
