<BUG>onError(Exceptions.failWithOverflow("Queue full?!"));} else {</BUG><CONTEXT>}@Overridepublic void onNext(T t) {if (!queue.offer(t)) {Operators.terminate(S, this);<extra_id_0>signalConsumer();}}</CONTEXT>
this.source = Objects.requireNonNull(source, "source");this.batchSize = batchSize;this.queueSupplier = Objects.requireNonNull(queueSupplier, "queueSupplier");