Enum FailingProtocol 

pub enum FailingProtocol {
    AcceptorFailsCritical,
    InitiatorFailsCritical,
    InitiatorFailsUnexpected,
    InitiatorSendsTopicTwice,
    AcceptorSendsTopic,
    NoError,
}

A sync implementation which returns a mocked error.

Variants

AcceptorFailsCritical

A critical error is triggered inside accept() after sync messages have been exchanged.

InitiatorFailsCritical

A critical error is triggered inside initiate() after the handshake is complete.

InitiatorFailsUnexpected

An unexpected behaviour error is triggered inside initiate() after the topic query has been sent.

InitiatorSendsTopicTwice

An unexpected behaviour error is triggered inside accept() by sending the topic twice from initiate().

AcceptorSendsTopic

An unexpected behaviour error is triggered inside initiate() by sending a topic from accept().

NoError

No errors are explicitly triggered; used for “happy path” test.

Trait Implementations

impl Clone for FailingProtocol

fn clone(&self) -> FailingProtocol

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FailingProtocol

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

Formats the value using the given formatter.

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

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

Custom identifier for this sync protocol implementation.

fn initiate<'async_trait>( self: Arc<Self>, topic: 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.