File tree 2 files changed +18
-17
lines changed
2 files changed +18
-17
lines changed Original file line number Diff line number Diff line change @@ -156,22 +156,23 @@ impl Eventloop {
156
156
} ) => {
157
157
let tunnel = Arc :: clone ( & self . tunnel ) ;
158
158
159
- match self . connection_request_tasks . try_push (
160
- ( req. client . id , req. reference . clone ( ) ) ,
161
- async move {
162
- let conn = tunnel
163
- . set_peer_connection_request (
164
- req. client . payload ,
165
- req. client . peer . into ( ) ,
166
- req. relays ,
167
- req. client . id ,
168
- req. expires_at ,
169
- req. resource ,
170
- )
171
- . await ?;
172
- Ok ( GatewayResponse :: ConnectionAccepted ( conn) )
173
- } ,
174
- ) {
159
+ let connection_request = async move {
160
+ let conn = tunnel
161
+ . set_peer_connection_request (
162
+ req. client . payload ,
163
+ req. client . peer . into ( ) ,
164
+ req. relays ,
165
+ req. client . id ,
166
+ req. expires_at ,
167
+ req. resource ,
168
+ )
169
+ . await ?;
170
+ Ok ( GatewayResponse :: ConnectionAccepted ( conn) )
171
+ } ;
172
+ match self
173
+ . connection_request_tasks
174
+ . try_push ( ( req. client . id , req. reference . clone ( ) ) , connection_request)
175
+ {
175
176
Err ( futures_bounded:: PushError :: BeyondCapacity ( _) ) => {
176
177
tracing:: warn!( "Too many connections requests, dropping existing one" ) ;
177
178
}
Original file line number Diff line number Diff line change 1
1
[toolchain ]
2
- channel = " 1.75 .0"
2
+ channel = " 1.76 .0"
You can’t perform that action at this time.
0 commit comments