Struct BlockingExecutor 

pub struct BlockingExecutor { /* private fields */ }

An executor that uses spawn_blocking for blocking operations.

This is useful for services that perform blocking I/O or CPU-intensive work that would block the async runtime.

Example

use tower_resilience_executor::BlockingExecutor;
use tokio::runtime::Handle;

let executor = BlockingExecutor::new(Handle::current());

Implementations

impl BlockingExecutor

pub fn new(handle: Handle) -> Self

Creates a new blocking executor using the given runtime handle.

pub fn current() -> Self

Creates a new blocking executor using the current runtime handle.

Panics

Panics if called from outside a tokio runtime.

Trait Implementations

impl Clone for BlockingExecutor

fn clone(&self) -> BlockingExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Executor for BlockingExecutor

fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawns a future onto this executor.