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 RillClientimpl Send for RillClientimpl Sync for RillClientimpl Unpin for RillClientimpl !UnwindSafe for RillClientBlanket 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 = TShould always be Self
pub fn vzip(self) -> V