async fn publish(
        &mut self,
        request_validation_receipt: bool,
        sgd_hash: ai_hash::AnySgdHash,
        ops: Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>,
        timeout_ms: Option<u64>,
    ) -> actor::AIngleP2pResult<()> {
        self.sender
            .publish(
                (*self.saf_hash).clone(),
                (*self.from_agent).clone(),
                request_validation_receipt,
                sgd_hash,
                ops,
                timeout_ms,
            )
            .await
    }
/// Publish data to the correct neighborhood.
Publish data to the correct neighborhood.
Publish data to the correct neighborhood .
async fn publish(
        &mut self,
        request_validation_receipt: bool,
        sgd_hash: ai_hash::AnySgdHash,
        ops: Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>,
        timeout_ms: Option<u64>,
    ) -> actor::AIngleP2pResult<()> {
        self.sender
            .publish(
                (*self.saf_hash).clone(),
                (*self.from_agent).clone(),
                request_validation_receipt,
                sgd_hash,
                ops,
                timeout_ms,
            )
            .await
    }
async fn publish ( & mut self , request_validation_receipt : bool , sgd_hash : ai_hash :: AnySgdHash , ops : Vec < ( ai_hash :: SgdOpHash , aingle_types :: sgd_op :: SgdOp ) > , timeout_ms : Option < u64 > , ) -> actor :: AIngleP2pResult < ( ) > { self . sender . publish ( ( * self . saf_hash ) . clone ( ) , ( * self . from_agent ) . clone ( ) , request_validation_receipt , sgd_hash , ops , timeout_ms , ) . await }
Publish data to the correct neighborhood.
Publish data to the correct neighborhood .
&mut self
request_validation_receipt
bool
sgd_hash
ai_hash::AnySgdHash
ops
Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>
timeout_ms
Option<u64>
&mut self
request_validation_receipt
bool
sgd_hash
ai_hash::AnySgdHash
ops
Vec<(ai_hash::SgdOpHash, aingle_types::sgd_op::SgdOp)>
timeout_ms
Option<u64>