Struct meio_ws::client::WsClient

pub struct WsClient<P, A> where
    A: Actor,  { /* fields omitted */ }

Implementations

impl<P, A> WsClient<P, A> where
    P: Protocol,
    A: Actor + InteractionHandler<WsClientStatus<P>> + ActionHandler<WsIncoming<P::ToClient>>, 

pub fn new(
    url: String,
    repeat_interval: Option<Duration>,
    address: Address<A>
) -> Self

Trait Implementations

impl<P, A> LiteTask for WsClient<P, A> where
    P: Protocol,
    A: Actor + InteractionHandler<WsClientStatus<P>> + ActionHandler<WsIncoming<P::ToClient>>, 

fn name(&self) -> String

Returns unique name of the LiteTask. Uses Uuid by default.

fn routine<'async_trait>(
    self,
    signal: ShutdownReceiver
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Routine of the task that can contain loops. It can taks into accout provided receiver to implement graceful interruption.

fn start<T>(self, supervisor: Option<T>) -> Controller where
    T: Into<Controller> + Send, 

Starts a lite task.