pub trait InitProtocol {
    type CustomErr: Debug + Send;

    // Required method
    fn initialize<'life0, 'async_trait>(
        &'life0 mut self,
        initializer: bool,
        local_pid: Pid,
        secret: u128
    ) -> Pin<Box<dyn Future<Output = Result<(Pid, Sid, u128), InitProtocolError<Self::CustomErr>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

Handshake: Used to connect 2 Channels.

Required Associated Types§

Required Methods§

source

fn initialize<'life0, 'async_trait>( &'life0 mut self, initializer: bool, local_pid: Pid, secret: u128 ) -> Pin<Box<dyn Future<Output = Result<(Pid, Sid, u128), InitProtocolError<Self::CustomErr>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementations on Foreign Types§

source§

impl<D, S, E> InitProtocol for (D, S)
where D: ReliableDrain<CustomErr = E> + Send, S: ReliableSink<CustomErr = E> + Send, E: Debug + Send,

§

type CustomErr = E

source§

fn initialize<'life0, 'async_trait>( &'life0 mut self, initializer: bool, local_pid: Pid, local_secret: u128 ) -> Pin<Box<dyn Future<Output = Result<(Pid, Sid, u128), InitProtocolError<E>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§