safe-async/polldance
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

example: allow concurrent read/write

Browse source
This commit is contained in:
Aode (lion) 2022-02-14 13:59:36 -06:00
parent 30654fddf9
commit 9aca91c6b3
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
examples/poll.rs
View file

@ -75,7 +75,11 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
}
}
poller.update_interests(&stream_key, Readiness::write() | Readiness::hangup());
if !bytes.is_empty() {
poller.update_interests(&stream_key, |interests| {
Readiness::write() | interests
});
}
}
if readiness.is_hangup() {
break 'l2;
@ -84,10 +88,9 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
match rustix::io::write(&*stream, &bytes) {
Ok(n) if n == bytes.len() => {
bytes = Vec::new();
poller.update_interests(
&stream_key,
Readiness::read() | Readiness::hangup(),
);
poller.update_interests(&stream_key, |_| {
Readiness::read() | Readiness::hangup()
});
}
Ok(n) => {
bytes = Vec::from(&bytes[n..]);