clementine_core::rpc::aggregator

Function nonce_distributor

Source
async fn nonce_distributor(
    agg_nonce_receiver: Receiver<AggNonceQueueItem>,
    partial_sig_streams: Vec<(Streaming<PartialSig>, Sender<VerifierDepositSignParams>)>,
    partial_sig_sender: Sender<(Vec<PartialSignature>, AggNonceQueueItem)>,
) -> Result<(), BridgeError>
Expand description

Reroutes aggregated nonces to the signature aggregator.