We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5ec0568 commit b3562a7Copy full SHA for b3562a7
src/packet_sources/macos.rs
@@ -335,7 +335,9 @@ impl ConnectionTask {
335
tokio::select! {
336
_ = self.shutdown.recv() => break,
337
Ok(()) = self.stream.writable(), if !write_buf.is_empty() => {
338
- self.stream.write_buf(&mut write_buf).await.context("failed to write to socket from buf")?;
+ let Ok(_) = self.stream.write_buf(&mut write_buf).await else {
339
+ break; // Client has disconnected.
340
+ };
341
if write_buf.is_empty() {
342
if let Some(tx) = drain_tx.take() {
343
tx.send(()).ok();
0 commit comments