3 releases
0.1.2 | May 29, 2019 |
---|---|
0.1.1 | Jan 19, 2018 |
0.1.0 | Jan 7, 2018 |
#1561 in Asynchronous
87 downloads per month
Used in 11 crates
(6 directly)
10KB
143 lines
fibers_tasque
lib.rs
:
A tasque extension specialized for fibers.
This provides an extension trait and the default task queues.
Examples
use fibers::{Executor, InPlaceExecutor};
use fibers_tasque::{AsyncCallError, DefaultCpuTaskQueue, DefaultIoTaskQueue, TaskQueueExt};
let mut executor = InPlaceExecutor::new().unwrap();
let future = DefaultCpuTaskQueue.async_call(|| 1 + 1);
assert_eq!(executor.run_future(future).unwrap(), Ok(2));
let future = DefaultIoTaskQueue.async_call(|| -> () { panic!() });
assert_eq!(executor.run_future(future).unwrap(), Err(AsyncCallError));
Dependencies
~3MB
~62K SLoC