Struct flo_state::Container

pub struct Container<S> { /* fields omitted */ }

Implementations

impl<S> Container<S> where
    S: Actor, 

pub fn new(initial_state: S) -> Self

pub fn addr(&self) -> Addr<S>

pub async fn send<M, '_>(&'_ self, message: M) -> Result<M::Result> where
    M: Message + Send + 'static,
    S: Handler<M>, 

Sends a message to the actor and wait for the result

pub async fn notify<M, '_>(&'_ self, message: M) -> Result<()> where
    M: Message<Result = ()> + Send + 'static,
    S: Handler<M>, 

Sends a message to the actor without waiting for the result

pub fn spawn<F>(&self, f: F) where
    F: Future<Output = ()> + Send + 'static, 

Spawns a future into the container. All futures spawned into the container will be cancelled if the container dropped.

pub async fn shutdown(self) -> Result<S>

Trait Implementations

impl<S: Debug> Debug for Container<S>

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.