Struct PingPongProtocol 

pub struct PingPongProtocol {}

A sync implementation where the initiator sends a ping message and the acceptor responds with a pong message.

Trait Implementations

impl Clone for PingPongProtocol

fn clone(&self) -> PingPongProtocol

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PingPongProtocol

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

Formats the value using the given formatter.

impl<'a> SyncProtocol<'a, SyncTestTopic> for PingPongProtocol

fn name(&self) -> &'static str

Custom identifier for this sync protocol implementation.

fn initiate<'async_trait>( self: Arc<Self>, topic_query: SyncTestTopic, tx: Box<&'a mut (dyn AsyncWrite + Send + Unpin)>, rx: Box<&'a mut (dyn AsyncRead + Send + Unpin)>, app_tx: Box<&'a mut (dyn Sink<FromSync<SyncTestTopic>, Error = SyncError> + Send + Unpin)>, ) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Initiate a sync protocol session over the provided bi-directional stream for the given topic query.

fn accept<'async_trait>( self: Arc<Self>, tx: Box<&'a mut (dyn AsyncWrite + Send + Unpin)>, rx: Box<&'a mut (dyn AsyncRead + Send + Unpin)>, app_tx: Box<&'a mut (dyn Sink<FromSync<SyncTestTopic>, Error = SyncError> + Send + Unpin)>, ) -> Pin<Box<dyn Future<Output = Result<(), SyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait,

Accept a sync protocol session over the provided bi-directional stream.