Struct ockam_transport_websocket::WebSocketRecvWorker [−][src]
pub struct WebSocketRecvWorker<AsyncStream> where
AsyncStream: AsyncRead + AsyncWrite + Unpin + Send + 'static, { /* fields omitted */ }
Trait Implementations
impl<AsyncStream> Worker for WebSocketRecvWorker<AsyncStream> where
AsyncStream: AsyncRead + AsyncWrite + Unpin + Send + 'static,
[src]
impl<AsyncStream> Worker for WebSocketRecvWorker<AsyncStream> where
AsyncStream: AsyncRead + AsyncWrite + Unpin + Send + 'static,
[src]The type of Message the Worker is sent in Self::handle_message
The API and other resources available for the worker during message processing.
Override initialisation behaviour
Override shutdown behaviour
#[must_use]fn handle_message<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_context: &'life1 mut Self::Context,
_msg: Routed<Self::Message>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
#[must_use]fn handle_message<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_context: &'life1 mut Self::Context,
_msg: Routed<Self::Message>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]Try to open and handle a typed message
Auto Trait Implementations
impl<AsyncStream> !RefUnwindSafe for WebSocketRecvWorker<AsyncStream>
impl<AsyncStream> Send for WebSocketRecvWorker<AsyncStream>
impl<AsyncStream> Sync for WebSocketRecvWorker<AsyncStream>
impl<AsyncStream> Unpin for WebSocketRecvWorker<AsyncStream>
impl<AsyncStream> !UnwindSafe for WebSocketRecvWorker<AsyncStream>