Struct Response 

pub struct Response<T> { /* private fields */ }

Response.

Notes

• When the response is dropped inside the actor and has not been used we receive a canceled on the caller side.

Implementations

impl<T> Response<T>

pub fn respond(self, value: T)

Send Response to caller.

Notes

• Ignores when the caller is not waiting for the response. When you want to handle this use Response::send.

pub async fn respond_execute<Fut, F>(self, value: F)

where Fut: Future<Output = T> + Send, F: FnOnce() -> Fut + Send,

Executes closure and respond with the result

pub fn send(self, value: T) -> Result<(), ActorError>

Try to send response to caller.

Errors

• Fails with ActorError::Canceled when the caller is not waiting for the result.

pub async fn execute<Fut, F>(self, value: F) -> Result<(), ActorError>

where Fut: Future<Output = T> + Send, F: FnOnce() -> Fut + Send,

Executes closure and respond with the result

pub fn spawn<Fut, F>(self, value: F)

where Fut: Future<Output = T> + Send + 'static, F: FnOnce() -> Fut + Send + 'static, T: Send + 'static,

Spawns a new task and executes given closure in it

pub fn spawn_with<Fut, F>(self, spawner: impl Borrow<TaskSpawner>, value: F)

where Fut: Future<Output = T> + Send + 'static, F: FnOnce() -> Fut + Send + 'static, T: Send + 'static,

Spawns a new task using the given spawner and executes given closure in it

pub fn spawn_local<Fut, F>(self, spawner: impl LocalTaskSpawner, value: F)

where Fut: Future<Output = T> + 'static, F: FnOnce() -> Fut + 'static, T: Send + 'static,

Spawns a new task using the given spawner and executes given closure in it

Trait Implementations

impl<T> Debug for Response<T>

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

Formats the value using the given formatter.