DeCarabas/fwd
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Some silly refactoring

Browse source
This commit is contained in:
John Doty 2023-11-25 07:57:52 -08:00
parent 519b7bc415
commit 00daedeb95
1 changed files with 2 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/server/mod.rs
View file

@ -14,13 +14,8 @@ async fn write_driver<Writer: AsyncWrite + Unpin>(
messages: &mut mpsc::Receiver<Message>,
writer: &mut MessageWriter<Writer>,
) -> () {
loop {
match messages.recv().await {
Some(m) => {
writer.write(m).await.expect("Failed to write the message")
}
None => break,
}
while let Some(m) = messages.recv().await {
writer.write(m).await.expect("Failed to write the message")
}
}