File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -252,8 +252,6 @@ struct StreamerSetup {
252252 near_config : NearConfig ,
253253}
254254
255- /// Races `sync` against `shutdown`. Returns `true` if `sync` completed first,
256- /// `false` if `shutdown` resolved first.
257255async fn await_sync_or_shutdown (
258256 sync : impl Future < Output = ( ) > ,
259257 shutdown : impl Future < Output = ( ) > ,
@@ -265,7 +263,7 @@ async fn await_sync_or_shutdown(
265263}
266264
267265#[ cfg( test) ]
268- #[ expect( non_snake_case) ] // tests follow `<system_under_test>__should_<assertion>` convention
266+ #[ expect( non_snake_case) ]
269267mod tests {
270268 use super :: await_sync_or_shutdown;
271269 use std:: future:: pending;
Original file line number Diff line number Diff line change @@ -317,11 +317,6 @@ pub fn spawn_real_indexer(
317317 }
318318}
319319
320- /// Waits for `sync` to resolve, racing it against `shutdown`.
321- ///
322- /// Returns `true` if `sync` completed first, or `false` if `shutdown` was
323- /// requested first. Racing the wait keeps a SIGTERM responsive during a long
324- /// initial state sync.
325320async fn await_sync_or_shutdown (
326321 sync : impl Future < Output = ( ) > ,
327322 shutdown : & CancellationToken ,
@@ -333,7 +328,7 @@ async fn await_sync_or_shutdown(
333328}
334329
335330#[ cfg( test) ]
336- #[ expect( non_snake_case) ] // tests follow `<system_under_test>__should_<assertion>` convention
331+ #[ expect( non_snake_case) ]
337332mod tests {
338333 use super :: await_sync_or_shutdown;
339334 use std:: future:: pending;
You can’t perform that action at this time.
0 commit comments