async fn notify_block_production_service(
    current_slot: Slot,
    block_proposers: &HashSet<PublicKeyBytes>,
    block_service_tx: &mut Sender<BlockServiceNotification>,
    log: &Logger,
) {
    if let Err(e) = block_service_tx
        .send(BlockServiceNotification {
            slot: current_slot,
            block_proposers: block_proposers.iter().copied().collect(),
        })
        .await
    {
        error!(
            log,
            "Failed to notify block service";
            "current_slot" => current_slot,
            "error" => %e
        );
    };
}
/// Notify the block service if it should produce a block.
Notify the block service if it should produce a block.
Notify the block service if it should produce a block .
async fn notify_block_production_service(
    current_slot: Slot,
    block_proposers: &HashSet<PublicKeyBytes>,
    block_service_tx: &mut Sender<BlockServiceNotification>,
    log: &Logger,
) {
    if let Err(e) = block_service_tx
        .send(BlockServiceNotification {
            slot: current_slot,
            block_proposers: block_proposers.iter().copied().collect(),
        })
        .await
    {
        error!(
            log,
            "Failed to notify block service";
            "current_slot" => current_slot,
            "error" => %e
        );
    };
}
async fn notify_block_production_service ( current_slot : Slot , block_proposers : & HashSet < PublicKeyBytes > , block_service_tx : & mut Sender < BlockServiceNotification > , log : & Logger , ) { if let Err ( e ) = block_service_tx . send ( BlockServiceNotification { slot : current_slot , block_proposers : block_proposers . iter ( ) . copied ( ) . collect ( ) , } ) . await { error ! ( log " " " " current_slot " " e ) ; } ; }
Notify the block service if it should produce a block.
Notify the block service if it should produce a block .
current_slot
Slot
block_proposers
&HashSet<PublicKeyBytes>
block_service_tx
&mut Sender<BlockServiceNotification>
log
&Logger