@@ -119,21 +119,24 @@ public void onHttpContentParsed(HttpContent content,
119
119
120
120
@ SuppressWarnings ("UnusedParameters" )
121
121
public void onHttpHeadersEncoded (HttpHeader httpHeader , FilterChainContext ctx ) {
122
- final HttpTransactionContext context = HttpTransactionContext .get (ctx .getConnection ());
122
+ final HttpTransactionContext context =
123
+ HttpTransactionContext .get (ctx .getConnection ());
123
124
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
+ }
127
128
}
128
129
129
130
public void onHttpContentEncoded (HttpContent content , FilterChainContext ctx ) {
130
- final HttpTransactionContext context = HttpTransactionContext .get (ctx .getConnection ());
131
+ final HttpTransactionContext context =
132
+ HttpTransactionContext .get (ctx .getConnection ());
131
133
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
+ }
137
140
}
138
141
139
142
public void onInitialLineParsed (HttpHeader httpHeader ,
0 commit comments