From c422fe8429e7b2d36e34e046d82a5b70203fa2d8 Mon Sep 17 00:00:00 2001 From: Stephane Landelle Date: Mon, 7 Dec 2015 16:53:27 +0100 Subject: [PATCH] minor clean up --- .../body/generator/SimpleFeedableBodyGenerator.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/client/src/main/java/org/asynchttpclient/request/body/generator/SimpleFeedableBodyGenerator.java b/client/src/main/java/org/asynchttpclient/request/body/generator/SimpleFeedableBodyGenerator.java index 12ed42b292..1cc64fe836 100755 --- a/client/src/main/java/org/asynchttpclient/request/body/generator/SimpleFeedableBodyGenerator.java +++ b/client/src/main/java/org/asynchttpclient/request/body/generator/SimpleFeedableBodyGenerator.java @@ -68,16 +68,16 @@ public BodyState transferTo(final ByteBuf target) throws IOException { private BodyState readNextChunk(ByteBuf target) throws IOException { BodyState res = BodyState.SUSPEND; while (target.isWritable() && state != BodyState.STOP) { - BodyChunk nextPart = queue.peek(); - if (nextPart == null) { + BodyChunk nextChunk = queue.peek(); + if (nextChunk == null) { // Nothing in the queue. suspend stream if nothing was read. (reads == 0) return res; - } else if (!nextPart.buffer.hasRemaining() && !nextPart.isLast) { + } else if (!nextChunk.buffer.hasRemaining() && !nextChunk.isLast) { // skip empty buffers queue.remove(); } else { res = BodyState.CONTINUE; - readChunk(target, nextPart); + readChunk(target, nextChunk); } } return res;