Minor cleanup for #735 + couple more of tests

Author: jknack

coverage-report/src/test/java/org/jooby/issues/Issue731.java

@@ -1,26 +1,51 @@
 package org.jooby.issues;
 
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.util.concurrent.Executors;
+
 import org.jooby.test.ServerFeature;
 import org.junit.Test;
 
-import java.util.concurrent.Executors;
-
 public class Issue731 extends ServerFeature {
 
   {
 
     executor("worker1", Executors.newSingleThreadExecutor());
 
-    post("/", deferred("worker1", req -> req.body(String.class)));
+    get("/731", deferred("worker1", req -> req.body().toOptional().orElse("nobody")));
+
+    post("/731", deferred("worker1", req -> req.body(String.class)));
+
+    post("/731/files",
+        deferred("worker1", req -> Files.readAllBytes(req.file("file").file().toPath())));
 
   }
 
   @Test
   public void appShouldBeAbleToReadTheRequestBodyWhenDeferred() throws Exception {
     request()
-            .post("/")
-            .body("HelloWorld!", "text/plain")
-            .expect(200)
-            .expect("HelloWorld!");
+        .post("/731")
+        .body("HelloWorld!", "text/plain")
+        .expect(200)
+        .expect("HelloWorld!");
+  }
+
+  @Test
+  public void appShouldBeAbleToReadTheFileWhenDeferred() throws Exception {
+    request()
+        .post("/731/files")
+        .multipart()
+        .file("file", "HelloWorld!".getBytes(StandardCharsets.UTF_8), "text/plain", "731.txt")
+        .expect(200)
+        .expect("HelloWorld!");
+  }
+
+  @Test
+  public void getShouldNotBeAffected() throws Exception {
+    request()
+        .get("/731")
+        .expect(200)
+        .expect("nobody");
   }
 }

jooby-netty/src/main/java/org/jooby/internal/netty/NettyRequest.java

@@ -244,13 +244,13 @@ public void startAsync(final Executor executor, final Runnable runnable) {
     channel.attr(NEED_FLUSH).set(false);
     channel.attr(ASYNC).set(true);
 
-    ReferenceCounted referenceCounted = ((ByteBufHolder) req).content();
-    referenceCounted.retain();
+    ReferenceCounted body = ((ByteBufHolder) req).content();
+    body.retain();
     executor.execute(() -> {
       try {
         runnable.run();
       } finally {
-        referenceCounted.release();
+        body.release();
       }
     });
   }