Struct ockam_transport_tcp::TcpSendWorker [−][src]
pub struct TcpSendWorker { /* fields omitted */ }
A TCP sending message worker
Create this worker type by calling
start_tcp_worker
!
This half of the worker is created when spawning a new connection worker pair, and listens for messages from the node message system to dispatch to a remote peer.
Trait Implementations
impl Worker for TcpSendWorker
[src]
impl Worker for TcpSendWorker
[src]type Context = Context
The API and other resources available for the worker during message processing.
type Message = TransportMessage
The type of Message the Worker is sent in Self::handle_message
fn handle_message<'life0, 'life1, 'async_trait>(
&'life0 mut self,
ctx: &'life1 mut Context,
msg: Routed<TransportMessage>
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
&'life0 mut self,
ctx: &'life1 mut Context,
msg: Routed<TransportMessage>
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
#[must_use]pub fn initialize<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_context: &'life1 mut Self::Context
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
#[must_use]
pub fn initialize<'life0, 'life1, 'async_trait>(&'life0 mut self,
_context: &'life1 mut Self::Context
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
pub fn shutdown(&mut self, _context: &mut Self::Context) -> Result<(), Error>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for TcpSendWorker
impl !RefUnwindSafe for TcpSendWorker
impl Send for TcpSendWorker
impl Send for TcpSendWorker
impl Sync for TcpSendWorker
impl Sync for TcpSendWorker
impl Unpin for TcpSendWorker
impl Unpin for TcpSendWorker
impl !UnwindSafe for TcpSendWorker
impl !UnwindSafe for TcpSendWorker
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,