File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -66,7 +66,7 @@ pub(crate) async fn check(
6666 // Split initial requests into: valid requests and request errors. Note that
6767 // this stream closure *owns* a wait guard, so we must drop the closure after
6868 // it's finished to avoid deadlock. This is done using the `.chain()` combinator.
69- let ( valid_initial_requests , request_errors) = requests
69+ let ( valid_requests , request_errors) = requests
7070 . inspect ( |_| progress. inc_length ( 1 ) )
7171 . map ( move |request| ( request, wait_guard. clone ( ) ) )
7272 . chain ( futures:: stream:: empty ( ) )
@@ -99,7 +99,7 @@ pub(crate) async fn check(
9999
100100 // Combine recursive requests and input requests.
101101 let requests = futures:: stream:: select_with_strategy (
102- valid_initial_requests ,
102+ valid_requests ,
103103 ReceiverStream :: new ( recursive_channel_recv) . take_until ( waiter. wait ( ) ) ,
104104 |( ) | futures:: stream:: PollNext :: Right , // Recursive requests consume memory, prefer those.
105105 ) ;
You can’t perform that action at this time.
0 commit comments