Struct zappot::base_ot::Sender

pub struct Sender;

Implementations

impl Sender

pub fn new() -> Self

Examples found in repository

crates/zappot/examples/co_base_ot.rs (line 29)

async fn sender(args: Args) -> Vec<[Block; 2]> {
    // Create a secure RNG to use in the protocol
    let mut rng = OsRng;
    let mut sender = Sender::new();
    // Create a channel by listening on a socket address. Once another party connect, this
    // returns the channel
    let (mut base_sender, _, mut base_receiver, _) =
        seec_channel::tcp::listen::<seec_channel::Sender<_>>(("127.0.0.1", args.port))
            .await
            .expect("Error listening for channel connection");
    let (ch_sender, mut ch_receiver) = sub_channel(&mut base_sender, &mut base_receiver, 8)
        .await
        .expect("Establishing sub channel");
    // Perform the random ots
    sender
        .send_random(args.num_ots, &mut rng, &ch_sender, &mut ch_receiver)
        .await
        .expect("Failed to generate ROTs")
}

Trait Implementations

impl BaseROTSender for Sender

type Msg = BaseOTMsg

fn send_random<'life0, 'life1, 'life2, 'life3, 'async_trait, RNG>( &'life0 mut self, count: usize, rng: &'life1 mut RNG, sender: &'life2 Sender<Self::Msg>, receiver: &'life3 mut Receiver<Self::Msg> ) -> Pin<Box<dyn Future<Output = Result<Vec<[Block; 2]>, Error<Self::Msg>>> + Send + 'async_trait>>

where RNG: RngCore + CryptoRng + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Send count number of random OTs via the provided channel.

impl Clone for Sender

fn clone(&self) -> Sender

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Sender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Sender

fn default() -> Sender

Returns the “default value” for a type.