File tree Expand file tree Collapse file tree 2 files changed +9
-0
lines changed
Expand file tree Collapse file tree 2 files changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -949,6 +949,7 @@ dependencies = [
949949 " http 1.2.0" ,
950950 " http-body" ,
951951 " pin-project-lite" ,
952+ " tokio" ,
952953]
953954
954955[[package ]]
@@ -1854,6 +1855,7 @@ dependencies = [
18541855 " futures" ,
18551856 " http 1.2.0" ,
18561857 " http-body" ,
1858+ " http-body-util" ,
18571859 " hyper" ,
18581860 " linkerd-error" ,
18591861 " linkerd-exp-backoff" ,
Original file line number Diff line number Diff line change @@ -190,6 +190,13 @@ where
190190 return Poll :: Ready ( Some ( Err ( Capped . into ( ) ) ) ) ;
191191 }
192192 }
193+ if this. replay_trailers {
194+ this. replay_trailers = false ;
195+ if let Some ( ref trailers) = state. trailers {
196+ tracing:: trace!( "Replaying trailers" ) ;
197+ return Poll :: Ready ( Some ( Ok ( Frame :: trailers ( trailers. clone ( ) ) ) ) ) ;
198+ }
199+ }
193200
194201 // If the inner body has previously ended, don't poll it again.
195202 //
You can’t perform that action at this time.
0 commit comments