Struct cosync::CosyncQueueHandle

pub struct CosyncQueueHandle<T: ?Sized> { /* private fields */ }

A handle to spawn tasks.

Examples

let mut cosync = Cosync::new();
let handler = cosync.create_queue_handle();

// make a thread and join it...
std::thread::spawn(move || {
    handler.queue(|mut input| async move {
        *input.get() = 20;
    });
})
.join()
.unwrap();

let mut value = 1;
cosync.run_blocking(&mut value);
assert_eq!(value, 20);

Implementations

impl<T: 'static + ?Sized> CosyncQueueHandle<T>

pub fn queue<Task, Out>(&self, task: Task) where
    Task: FnOnce(CosyncInput<T>) -> Out + Send + 'static,
    Out: Future<Output = ()> + Send, 

Adds a new Task to the TaskQueue.

Trait Implementations

impl<T: ?Sized> Clone for CosyncQueueHandle<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + ?Sized> Debug for CosyncQueueHandle<T>

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

Formats the value using the given formatter.

impl<T: ?Sized> Send for CosyncQueueHandle<T>

impl<T: ?Sized> Sync for CosyncQueueHandle<T>