Struct LocalSpawner 

pub struct LocalSpawner<C, T> { /* private fields */ }

Implementations

impl<C: 'static + Send, T: Task<C> + 'static + Send> LocalSpawner<C, T>

pub fn new_current() -> Self

Create a new LocalSpawner instance use [tokio::runtime::Builder::new_current_thread].

pub fn new(runtime: Option<Arc<Runtime>>) -> Self

Create a new LocalSpawner instance use supplied [tokio::runtime::Runtime].

pub fn spawn(&self, task: T, tx: Sender<TaskHandler<C>>)

Spawn a task

This will kick task to start it’s main handler loop.

User need to prepare a [tokio::sync::oneshot] channel to receive notification when task successful started.

Example

let spawner = LocalSpawner::new_current();
let (tx, rx) = oneshot::channel();
let file = File::new(1);
spawner.spawn(file, tx);
let handler1 = rx.blocking_recv().expect("failed to get back file handler");

Trait Implementations

impl<C, T> Clone for LocalSpawner<C, T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.