Lunatic Tasks

Lunatic中任务处理的工具。

许可协议

本项目受MIT OR Apache-2.0 许可协议许可。

lib.rs:

Lunatic中任务处理的工具。

示例

let mut tasks = (0..5).rev().tasks_unordered(3, |num| {
    lunatic::sleep(Duration::from_millis(num as u64 * 200));
    num
});
assert_eq!(tasks.next(), Some(2));
assert_eq!(tasks.next(), Some(3));
assert_eq!(tasks.next(), Some(0));
assert_eq!(tasks.next(), Some(1));
assert_eq!(tasks.next(), Some(4));
assert_eq!(tasks.next(), None);