Struct TopicHandshakeAcceptor 

pub struct TopicHandshakeAcceptor<T, Evt> {
    pub event_tx: Sender<Evt>,
    /* private fields */
}

Acceptor side of the topic handshake protocol.

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

Fields

event_tx: Sender<Evt>

Implementations

impl<T, Evt> TopicHandshakeAcceptor<T, Evt>

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

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

Trait Implementations

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

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

type Error = TopicHandshakeError<T>

type Output = T

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>