Struct flo_state::Owner

pub struct Owner<S> { /* private fields */ }

Implementations

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

pub fn new(initial_state: S) -> Self

pub fn build() -> OwnerBuilder<S>

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 send_timeout<M>(
    &self,
    timeout: Duration,
    message: M
) -> Result<M::Result>where
    M: Message + Send + 'static,
    S: Handler<M>,

Sends a message to the actor and wait for the result, but only for a limited time.

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 async fn notify_timeout<M>(&self, timeout: Duration, message: M) -> Result<()>where
    M: Message<Result = ()> + Send + 'static,
    S: Handler<M>,

Sends a message to the actor without waiting for the result, but only for a limited time.

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 Owner<S>

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

Formats the value using the given formatter.

impl<S> Drop for Owner<S>

fn drop(&mut self)

Executes the destructor for this type.