format

Author: slandelle

api/src/main/java/org/asynchttpclient/request/body/generator/FeedableBodyGenerator.java

@@ -93,22 +93,23 @@ public long read(final ByteBuffer buffer) throws IOException {
                 // skip empty buffers
                 // if we return 0 here it would suspend the stream - we don't want that
                 queue.remove();
-                if(nextPart.isLast) {
-                    state =  writeChunkBoundaries ? PushBodyState.CLOSING : PushBodyState.FINISHED;
+                if (nextPart.isLast) {
+                    state = writeChunkBoundaries ? PushBodyState.CLOSING : PushBodyState.FINISHED;
                 }
                 return read(buffer);
             }
             int capacity = buffer.remaining() - 10; // be safe (we'll have to add size, ending, etc.)
             int size = Math.min(nextPart.buffer.remaining(), capacity);
             if (size != 0) {
-                if(writeChunkBoundaries) {
+                if (writeChunkBoundaries) {
                     buffer.put(Integer.toHexString(size).getBytes(US_ASCII));
                     buffer.put(END_PADDING);
                 }
                 for (int i = 0; i < size; i++) {
                     buffer.put(nextPart.buffer.get());
                 }
-                if(writeChunkBoundaries) buffer.put(END_PADDING);
+                if (writeChunkBoundaries)
+                    buffer.put(END_PADDING);
             }
             if (!nextPart.buffer.hasRemaining()) {
                 if (nextPart.isLast) {

api/src/test/java/org/asynchttpclient/request/body/ChunkingTest.java

@@ -100,9 +100,9 @@ public void doTestWithFeedableBodyGenerator(InputStream is) throws Throwable {
     }
 
     private void feed(FeedableBodyGenerator feedableBodyGenerator, InputStream is) throws IOException {
-        try(InputStream inputStream = is) {
+        try (InputStream inputStream = is) {
             byte[] buffer = new byte[512];
-            for(int i =0; (i = inputStream.read(buffer)) > -1;) {
+            for (int i = 0; (i = inputStream.read(buffer)) > -1;) {
                 byte[] chunk = new byte[i];
                 System.arraycopy(buffer, 0, chunk, 0, i);
                 feedableBodyGenerator.feed(ByteBuffer.wrap(chunk), false);
@@ -114,12 +114,11 @@ private void feed(FeedableBodyGenerator feedableBodyGenerator, InputStream is) t
 
     private AsyncHttpClientConfig.Builder httpClientBuilder() {
         return new AsyncHttpClientConfig.Builder()//
-            .setAllowPoolingConnections(true)//
-            .setMaxConnectionsPerHost(1)//
-            .setMaxConnections(1)//
-            .setConnectTimeout(1000)//
-            .setRequestTimeout(1000)
-            .setFollowRedirect(true);
+                .setAllowPoolingConnections(true)//
+                .setMaxConnectionsPerHost(1)//
+                .setMaxConnections(1)//
+                .setConnectTimeout(1000)//
+                .setRequestTimeout(1000).setFollowRedirect(true);
     }
 
     private void waitForAndAssertResponse(ListenableFuture<Response> responseFuture) throws InterruptedException, java.util.concurrent.ExecutionException, IOException {

api/src/test/java/org/asynchttpclient/request/body/generator/FeedableBodyGeneratorTest.java

@@ -65,7 +65,7 @@ public void readingBytesReturnsFedContentWithoutChunkBoundariesWhenDisabled() th
 
   private byte[] readFromBody(Body body) throws IOException {
     ByteBuffer byteBuffer = ByteBuffer.allocate(512);
-    long read = body.read(byteBuffer);
+    body.read(byteBuffer);
     byteBuffer.flip();
     byte[] readBytes = new byte[byteBuffer.remaining()];
     byteBuffer.get(readBytes);
@@ -84,4 +84,4 @@ public int getCalls() {
       return calls;
     }
   }
-}
+}

providers/netty3/src/main/java/org/asynchttpclient/netty/request/body/BodyChunkedInput.java

@@ -58,7 +58,7 @@ public Object nextChunk() throws Exception {
             if (r < 0L) {
                 endOfInput = true;
                 return null;
-            } else if(r == 0 && body instanceof FeedableBodyGenerator.PushBody) {
+            } else if (r == 0 && body instanceof FeedableBodyGenerator.PushBody) {
                 //this will suspend the stream in ChunkedWriteHandler
                 return null;
             } else {

providers/netty4/src/main/java/org/asynchttpclient/netty/request/body/BodyChunkedInput.java

@@ -58,7 +58,7 @@ public ByteBuf readChunk(ChannelHandlerContext ctx) throws Exception {
             if (r < 0L) {
                 endOfInput = true;
                 return null;
-            } else if(r == 0 && body instanceof FeedableBodyGenerator.PushBody) {
+            } else if (r == 0 && body instanceof FeedableBodyGenerator.PushBody) {
                 //this will suspend the stream in ChunkedWriteHandler
                 return null;
             } else {

providers/netty4/src/main/java/org/asynchttpclient/netty/request/body/NettyBodyBody.java

@@ -68,7 +68,7 @@ public void write(final Channel channel, NettyResponseFuture<?> future) throws I
 
             BodyGenerator bg = future.getRequest().getBodyGenerator();
             if (bg instanceof FeedableBodyGenerator) {
-                final FeedableBodyGenerator feedableBodyGenerator = FeedableBodyGenerator.class.cast(bg);
+                final FeedableBodyGenerator feedableBodyGenerator = (FeedableBodyGenerator) bg;
                 feedableBodyGenerator.setWriteChunkBoundaries(false);
                 feedableBodyGenerator.setListener(new FeedListener() {
                     @Override