PromiseOut-rust
promiseOut的rust版本
add cargo.toml
toml
[dependencies]
promise_out = "0.1.0"
example
```rust
[test]
fn testpromiseoutresolve() {
let (op, opa) = Producer::on(async {
println!("我等到了{:?}", opa.await);
})
});
let task2 = thread::spawn(move || {
block_on(async {
println!("我发送了了{:?}", op.resolve(String::from("🍓")));
})
});
task1.join().expect("The task1 thread has panicked");
task2.join().expect("The task2 thread has panicked");
}
[test]
fn testpromiseoutreject() {
let (a, b) = Producer::::new();
let task1 = thread::spawn(|| {
blockon(async {
println!("我等到了{:?}", b.await);
})
});
let task2 = thread::spawn(|| {
block_on(async {
println!("我发送了了{:?}", a.reject(String::from("reject!!")));
})
});
task1.join().expect("The task1 thread has panicked");
task2.join().expect("The task2 thread has panicked");
}
```