src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/BufferingSubscriber.java
equal
deleted
inserted
replaced
278 |
278 |
279 if (s != ACTIVE) |
279 if (s != ACTIVE) |
280 throw new InternalError("onNext on inactive subscriber"); |
280 throw new InternalError("onNext on inactive subscriber"); |
281 |
281 |
282 synchronized (buffersLock) { |
282 synchronized (buffersLock) { |
283 accumulatedBytes += Utils.accumulateBuffers(internalBuffers, item); |
283 internalBuffers.addAll(item); |
|
284 accumulatedBytes += remaining(item); |
284 } |
285 } |
285 |
286 |
286 downstreamSubscription.pushDemanded(); |
287 downstreamSubscription.pushDemanded(); |
287 } |
288 } |
288 |
289 |