typo

AsyncHttpClient · Jul 7, 2015 · e9d13ec · e9d13ec
1 parent 1d965bb
commit e9d13ec
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 9 deletions.
diff --git a/api/src/main/java/org/asynchttpclient/AsyncCompletionHandler.java b/api/src/main/java/org/asynchttpclient/AsyncCompletionHandler.java
@@ -96,7 +96,7 @@ public State onHeadersWritten() {
      *
      * @return a {@link org.asynchttpclient.AsyncHandler.State} telling to CONTINUE or ABORT the current processing.
      */
-    public State onContentWriten() {
+    public State onContentWritten() {
         return State.CONTINUE;
     }
 

diff --git a/api/src/main/java/org/asynchttpclient/handler/ProgressAsyncHandler.java b/api/src/main/java/org/asynchttpclient/handler/ProgressAsyncHandler.java
@@ -35,7 +35,7 @@ public interface ProgressAsyncHandler<T> extends AsyncHandler<T> {
      *
      * @return a {@link AsyncHandler.State} telling to CONTINUE or ABORT the current processing.
      */
-    State onContentWriten();
+    State onContentWritten();
 
     /**
      * Invoked when the I/O operation associated with the {@link Request} body wasn't fully written in a single I/O write

diff --git a/api/src/main/java/org/asynchttpclient/simple/SimpleAsyncHttpClient.java b/api/src/main/java/org/asynchttpclient/simple/SimpleAsyncHttpClient.java
@@ -711,8 +711,8 @@ public AsyncHandler.State onHeadersWritten() {
             return delegate.onHeadersWritten();
         }
 
-        public AsyncHandler.State onContentWriten() {
+        public AsyncHandler.State onContentWritten() {
-            return delegate.onContentWriten();
+            return delegate.onContentWritten();
         }
 
         public AsyncHandler.State onContentWriteProgress(long amount, long current, long total) {

diff --git a/api/src/test/java/org/asynchttpclient/request/body/ZeroCopyFileTest.java b/api/src/test/java/org/asynchttpclient/request/body/ZeroCopyFileTest.java
@@ -81,7 +81,7 @@ public State onHeadersWritten() {
                     return State.CONTINUE;
                 }
 
-                public State onContentWriten() {
+                public State onContentWritten() {
                     operationCompleted.set(true);
                     return State.CONTINUE;
                 }

diff --git a/api/src/test/java/org/asynchttpclient/test/EventCollectingHandler.java b/api/src/test/java/org/asynchttpclient/test/EventCollectingHandler.java
@@ -64,9 +64,9 @@ public State onHeadersWritten() {
     }
 
     @Override
-    public State onContentWriten() {
+    public State onContentWritten() {
         firedEvents.add("ContentWritten");
-        return super.onContentWriten();
+        return super.onContentWritten();
     }
 
     @Override

diff --git a/providers/netty3/src/main/java/org/asynchttpclient/netty/request/ProgressListener.java b/providers/netty3/src/main/java/org/asynchttpclient/netty/request/ProgressListener.java
@@ -79,7 +79,7 @@ public void operationComplete(ChannelFuture cf) {
                 if (notifyHeaders) {
                     ProgressAsyncHandler.class.cast(asyncHandler).onHeadersWritten();
                 } else {
-                    ProgressAsyncHandler.class.cast(asyncHandler).onContentWriten();
+                    ProgressAsyncHandler.class.cast(asyncHandler).onContentWritten();
                 }
             }
         }

diff --git a/providers/netty4/src/main/java/org/asynchttpclient/netty/request/ProgressListener.java b/providers/netty4/src/main/java/org/asynchttpclient/netty/request/ProgressListener.java
@@ -90,7 +90,7 @@ public void operationComplete(ChannelProgressiveFuture cf) {
                 if (notifyHeaders) {
                     progressAsyncHandler.onHeadersWritten();
                 } else {
-                    progressAsyncHandler.onContentWriten();
+                    progressAsyncHandler.onContentWritten();
                 }
             }
         }