Struct sc_service::config::TaskExecutor

pub struct TaskExecutor(_);

Callable object that execute tasks.

This struct can be created easily using Into.

Examples

Using tokio

use futures::future::FutureExt;
use tokio::runtime::Runtime;

let runtime = Runtime::new().unwrap();
let handle = runtime.handle().clone();
let task_executor: TaskExecutor = (move |future, _task_type| {
    handle.spawn(future).map(|_| ())
}).into();

Using async-std

let task_executor: TaskExecutor = (|future, _task_type| {
    // NOTE: async-std's JoinHandle is not a Result so we don't need to map the result
    async_std::task::spawn(future)
}).into();

Implementations

impl TaskExecutor

pub fn spawn(
    &self,
    future: Pin<Box<dyn Future<Output = ()> + Send>>,
    task_type: TaskType
) -> Pin<Box<dyn Future<Output = ()> + Send>>

Spawns a new asynchronous task.

Trait Implementations

impl Clone for TaskExecutor

fn clone(&self) -> TaskExecutor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TaskExecutor

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

Formats the value using the given formatter.

impl<F, FUT> From<F> for TaskExecutor where
    F: Fn(Pin<Box<dyn Future<Output = ()> + Send>>, TaskType) -> FUT + Send + Sync + 'static,
    FUT: Future<Output = ()> + Send + 'static, 

fn from(func: F) -> Self

Performs the conversion.