@@ -119,21 +119,24 @@ public void onHttpContentParsed(HttpContent content,
119119
120120 @ SuppressWarnings ("UnusedParameters" )
121121 public void onHttpHeadersEncoded (HttpHeader httpHeader , FilterChainContext ctx ) {
122- final HttpTransactionContext context = HttpTransactionContext .get (ctx .getConnection ());
122+ final HttpTransactionContext context =
123+ HttpTransactionContext .get (ctx .getConnection ());
123124 final AsyncHandler handler = context .getHandler ();
124- if (handler instanceof TransferCompletionHandler ) {
125- ((TransferCompletionHandler ) handler ).onHeaderWriteCompleted ();
126- }
125+ if (handler instanceof TransferCompletionHandler ) {
126+ ((TransferCompletionHandler ) handler ).onHeaderWriteCompleted ();
127+ }
127128 }
128129
129130 public void onHttpContentEncoded (HttpContent content , FilterChainContext ctx ) {
130- final HttpTransactionContext context = HttpTransactionContext .get (ctx .getConnection ());
131+ final HttpTransactionContext context =
132+ HttpTransactionContext .get (ctx .getConnection ());
131133 final AsyncHandler handler = context .getHandler ();
132- if (handler instanceof TransferCompletionHandler ) {
133- final int written = content .getContent ().remaining ();
134- final long total = context .getTotalBodyWritten ().addAndGet (written );
135- ((TransferCompletionHandler ) handler ).onContentWriteProgress (written , total , content .getHttpHeader ().getContentLength ());
136- }
134+ if (handler instanceof TransferCompletionHandler ) {
135+ final int written = content .getContent ().remaining ();
136+ final long total = context .getTotalBodyWritten ().addAndGet (written );
137+ ((TransferCompletionHandler ) handler ).onContentWriteProgress (
138+ written , total , content .getHttpHeader ().getContentLength ());
139+ }
137140 }
138141
139142 public void onInitialLineParsed (HttpHeader httpHeader ,
0 commit comments