Struct TopicHandshakeInitiator 

pub struct TopicHandshakeInitiator<T, Evt> {
    pub topic: T,
    pub event_tx: Sender<Evt>,
}

Initiator side of the topic handshake protocol.

After the protocol is complete both peers know the T of the initiator.

Fields

topic: T

event_tx: Sender<Evt>

Implementations

impl<T, Evt> TopicHandshakeInitiator<T, Evt>

where T: Clone + for<'de> Deserialize<'de> + Serialize, Evt: From<TopicHandshakeEvent<T>>,

pub fn new(topic: T, event_tx: Sender<Evt>) -> Self

Trait Implementations

impl<T, Evt> Protocol for TopicHandshakeInitiator<T, Evt>

where T: Clone + Debug + for<'de> Deserialize<'de> + Serialize + Send + Sync + 'static, Evt: From<TopicHandshakeEvent<T>>,

type Error = TopicHandshakeError<T>

type Output = ()

type Message = TopicHandshakeMessage<T>

async fn run( self, sink: &mut (impl Sink<Self::Message, Error = impl Debug> + Unpin), stream: &mut (impl Stream<Item = Result<Self::Message, impl Debug>> + Unpin), ) -> Result<Self::Output, Self::Error>