pub async fn run<T>(&self, task: T, executor_type: ExecutorType) -> Result<T::Output>
    where
        T: Future + Send + 'static,
        T::Output: Send + 'static,
    {
        // run on the dedicated executor
        self.executor(executor_type)
            .spawn(task)
            // wait on the *current* tokio executor
            .await
            .context(TaskJoinError)
    }
/// Runs the specified Future (and any tasks it spawns) on the
/// specified executor, returning the result of the computation.
Runs the specified Future (and any tasks it spawns) on the
specified executor, returning the result of the computation.
Runs the specified Future ( and any tasks it spawns ) on the specified executor returning the result of the computation .
pub async fn run<T>(&self, task: T, executor_type: ExecutorType) -> Result<T::Output>
    where
        T: Future + Send + 'static,
        T::Output: Send + 'static,
    {
        // run on the dedicated executor
        self.executor(executor_type)
            .spawn(task)
            // wait on the *current* tokio executor
            .await
            .context(TaskJoinError)
    }
pub async fn run < T > ( & self , task : T , executor_type : ExecutorType ) -> Result < T :: Output > where T : Future + Send + ' static , T :: Output : Send + ' static , { // run on the dedicated executor self . executor ( executor_type ) . spawn ( task ) // wait on the *current* tokio executor . await . context ( TaskJoinError ) }
Runs the specified Future (and any tasks it spawns) on the
specified executor, returning the result of the computation.
Runs the specified Future ( and any tasks it spawns ) on the specified executor returning the result of the computation .
&self
task
T
executor_type
ExecutorType
&self
task
T
executor_type
ExecutorType