pub struct DummyProtocol {}Expand description
A sync implementation which fulfills basic protocol requirements but nothing more
Trait Implementations§
Source§impl Debug for DummyProtocol
impl Debug for DummyProtocol
Source§impl<'a> SyncProtocol<'a, SyncTestTopic> for DummyProtocol
impl<'a> SyncProtocol<'a, SyncTestTopic> for DummyProtocol
Source§fn name(&self) -> &'static str
fn name(&self) -> &'static str
Custom identifier for this sync protocol implementation. Read more
Source§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,
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. Read more
Source§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,
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. Read more
Auto Trait Implementations§
impl Freeze for DummyProtocol
impl RefUnwindSafe for DummyProtocol
impl Send for DummyProtocol
impl Sync for DummyProtocol
impl Unpin for DummyProtocol
impl UnwindSafe for DummyProtocol
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more