Struct BlockingTaskletAdapter 

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

Isolates synchronous tasklet work behind a bounded Tokio blocking pool.

The semaphore limits submitted blocking calls independently of Tokio’s process-wide blocking-thread limit. This adapter requires the launch future to be polled inside a Tokio runtime, but does not create or own one.

Implementations

impl<T> BlockingTaskletAdapter<T>

where T: BlockingTasklet,

pub fn new(tasklet: T, maximum_concurrency: NonZeroUsize) -> Self

Constructs an adapter with an explicit nonzero concurrency bound.

Trait Implementations

impl<T> Debug for BlockingTaskletAdapter<T>

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

Formats the value using the given formatter.

impl<T> Tasklet for BlockingTaskletAdapter<T>

where T: BlockingTasklet,

fn execute<'a>( &'a self, context: TaskletContext<'a>, ) -> BoxFuture<'a, Result<TaskletOutcome, TaskletError>>

Executes the step body once.