File tree Expand file tree Collapse file tree 3 files changed +7
-7
lines changed
tonic/src/transport/server Expand file tree Collapse file tree 3 files changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -177,9 +177,9 @@ where
177
177
return Poll :: Ready ( Some ( Ok ( Frame :: data ( bytes) ) ) ) ;
178
178
}
179
179
180
- let mut this = self . as_mut ( ) . project ( ) ;
180
+ let this = self . as_mut ( ) . project ( ) ;
181
181
182
- match ready ! ( this. inner. as_mut ( ) . poll_frame( cx) ) {
182
+ match ready ! ( this. inner. poll_frame( cx) ) {
183
183
Some ( Ok ( frame) ) if frame. is_data ( ) => this
184
184
. buf
185
185
. put ( frame. into_data ( ) . unwrap_or_else ( |_| unreachable ! ( ) ) ) ,
@@ -217,9 +217,9 @@ where
217
217
mut self : Pin < & mut Self > ,
218
218
cx : & mut Context < ' _ > ,
219
219
) -> Poll < Option < Result < Frame < Bytes > , Status > > > {
220
- let mut this = self . as_mut ( ) . project ( ) ;
220
+ let this = self . as_mut ( ) . project ( ) ;
221
221
222
- match ready ! ( this. inner. as_mut ( ) . poll_frame( cx) ) {
222
+ match ready ! ( this. inner. poll_frame( cx) ) {
223
223
Some ( Ok ( frame) ) if frame. is_data ( ) => {
224
224
let mut data = frame. into_data ( ) . unwrap_or_else ( |_| unreachable ! ( ) ) ;
225
225
let mut res = data. copy_to_bytes ( data. remaining ( ) ) ;
Original file line number Diff line number Diff line change @@ -159,9 +159,9 @@ where
159
159
type Output = Result < Response < Body > , E > ;
160
160
161
161
fn poll ( self : Pin < & mut Self > , cx : & mut Context < ' _ > ) -> Poll < Self :: Output > {
162
- let mut this = self . project ( ) ;
162
+ let this = self . project ( ) ;
163
163
164
- match this. case . as_mut ( ) . project ( ) {
164
+ match this. case . project ( ) {
165
165
CaseProj :: GrpcWeb { future, accept } => {
166
166
let res = ready ! ( future. poll( cx) ) ?;
167
167
Original file line number Diff line number Diff line change 52
52
where
53
53
IE : Into < crate :: BoxError > ,
54
54
{
55
- match ready ! ( self . as_mut( ) . project( ) . inner. as_mut ( ) . poll_next( cx) ) {
55
+ match ready ! ( self . as_mut( ) . project( ) . inner. poll_next( cx) ) {
56
56
Some ( Ok ( io) ) => Poll :: Ready ( Some ( Ok ( ServerIo :: new_io ( io) ) ) ) ,
57
57
Some ( Err ( e) ) => match handle_tcp_accept_error ( e) {
58
58
ControlFlow :: Continue ( ( ) ) => {
You can’t perform that action at this time.
0 commit comments