Flowync
Quick Example
use flowync::Flower;
fn main() {
let flower = Flower::<i32, String>::new(1);
std::thread::spawn({
let handle = flower.handle();
move || {
for i in 0..10 {
// Send current value through channel, will block the spawned thread
// until the option value successfully being polled in the main thread.
handle.send(i);
// // Return error if the job is failure, for example:
// if i >= 3 {
// return handle.err("Err".to_string());
// }
}
// And return ok if the job successfully completed.
return handle.ok("Ok".to_string());
}
});
let mut exit = false;
loop {
// Instead of polling the mutex over and over,
// the fn will be activated automatically if the handle sending or return a value
// and will deactivate itself if the result value successfully received.
// Note: this fn is non-blocking (won't block the current thread).
flower.try_recv(
|value| {
println!("{}", value);
},
|result| {
match result {
Ok(value) => {
println!("{}", value);
}
Err(e) => {
println!("{}", e);
}
}
exit = true;
},
);
if exit {
break;
}
}
}
More examples
can be found here here
40 Dec 20, 2022
22 Oct 13, 2022
2 Oct 9, 2022
7 Oct 26, 2022
5 Dec 15, 2022
97 Jun 26, 2023
9 Aug 7, 2023
3 Jul 31, 2023
22 Dec 6, 2022
11 Nov 24, 2022
6 May 6, 2022
3 May 18, 2022
4 Sep 3, 2022
11 Dec 30, 2022
5 Nov 3, 2022
3 Dec 16, 2022
5 Mar 16, 2023
3 Feb 28, 2024
35 Sep 4, 2021
13 Nov 14, 2021
484 Jan 7, 2023
304 Dec 27, 2022
756 Dec 30, 2022
22 Aug 23, 2022
9 Sep 27, 2022
294 Dec 23, 2022
94 Oct 26, 2022
5 Mar 5, 2023
90 Jan 2, 2024