Struct Blocking 

pub struct Blocking<Input = NoInput, Output = ()> { /* private fields */ }

A new task running in a different thread.

Implementations

impl<Input: Send + 'static, Output: Send + 'static> Blocking<Input, Output>

pub async fn spawn<F: Future<Output = Output>>( work: impl FnOnce(InputReceiver<Input>) -> F + Send + 'static, ) -> Self

Spawns a blocking task on a new thread with a stream of input messages.

pub async fn join(self) -> Output

Waits for the task to complete and returns its output.

pub fn send(&self, message: Input) -> Result<(), SendError<Input>>

Sends a message to the task.