@@ -475,19 +475,20 @@ impl Validator {
475
475
where
476
476
S : SubsystemSender < RuntimeApiMessage > ,
477
477
{
478
- // Note: request_validators and request_session_index_for_child do not and cannot
479
- // run concurrently: they both have a mutable handle to the same sender.
478
+ // Note: request_validators, request_disabled_validators and request_session_index_for_child
479
+ // do not and cannot run concurrently: they both have a mutable handle to the same sender.
480
480
// However, each of them returns a oneshot::Receiver, and those are resolved concurrently.
481
- let ( validators, session_index) = futures:: try_join!(
481
+ let ( validators, disabled_validators , session_index) = futures:: try_join!(
482
482
request_validators( parent, sender) . await ,
483
+ request_disabled_validators( parent, sender) . await ,
483
484
request_session_index_for_child( parent, sender) . await ,
484
485
) ?;
485
486
486
487
let signing_context = SigningContext { session_index : session_index?, parent_hash : parent } ;
487
488
488
489
let validators = validators?;
489
490
490
- let disabled_validators = request_disabled_validators ( parent , sender ) . await . await ? ?;
491
+ let disabled_validators = disabled_validators ?;
491
492
492
493
Self :: construct ( & validators, & disabled_validators, signing_context, keystore)
493
494
}
0 commit comments