Struct rill_client::RillClient [−][src]
pub struct RillClient { /* fields omitted */ }
Implementations
Trait Implementations
Asyncronous method that receives incoming message.
fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
msg: WsIncoming<ServiceEnvelope<ClientProtocol, ClientResponse, ClientServiceRequest>>,
_ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
msg: WsIncoming<ServiceEnvelope<ClientProtocol, ClientResponse, ClientServiceRequest>>,
_ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Asyncronous method that receives incoming message.
Asyncronous method that receives incoming message.
Called when the Actor
terminated by another actor. Read more
fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_id: IdOf<WsClient<ClientProtocol, Self>>,
_tag: (),
_result: Result<(), TaskError>,
_ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn handle<'life0, 'life1, 'async_trait>(
&'life0 mut self,
_id: IdOf<WsClient<ClientProtocol, Self>>,
_tag: (),
_result: Result<(), TaskError>,
_ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
Called when the Task
finished.
Auto Trait Implementations
impl !RefUnwindSafe for RillClient
impl Send for RillClient
impl Sync for RillClient
impl Unpin for RillClient
impl !UnwindSafe for RillClient
Blanket Implementations
Mutably borrows from an owned value. Read more
Asyncronous method that receives incoming message.
Asyncronous method that receives incoming message.
impl<T, C, M> InstantActionHandler<TaskDone<C, M>> for T where
C: LiteTask,
T: TaskEliminated<C, M>,
M: Tag,
impl<T, C, M> InstantActionHandler<TaskDone<C, M>> for T where
C: LiteTask,
T: TaskEliminated<C, M>,
M: Tag,
Asyncronous method that receives incoming message.
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self
pub fn vzip(self) -> V