src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http1AsyncReceiver.java
equal
deleted
inserted
replaced
372 this.delegate = null; |
372 this.delegate = null; |
373 } |
373 } |
374 } |
374 } |
375 } |
375 } |
376 |
376 |
377 // Callback: Consumer of ByteBufferReference |
377 // Callback: Consumer of ByteBuffer |
378 private void asyncReceive(ByteBuffer buf) { |
378 private void asyncReceive(ByteBuffer buf) { |
379 debug.log(Level.DEBUG, "Putting %s bytes into the queue", buf.remaining()); |
379 debug.log(Level.DEBUG, "Putting %s bytes into the queue", buf.remaining()); |
380 received.addAndGet(buf.remaining()); |
380 received.addAndGet(buf.remaining()); |
381 queue.offer(buf); |
381 queue.offer(buf); |
382 |
382 |