Skip to content

Commit 9243db2

Browse files
committed
error: signal TransportDisconnect on unregisterin resource on write failure
1 parent bc4e2e3 commit 9243db2

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/reactor.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -723,7 +723,9 @@ impl<H: Handler, P: Poll> Runtime<H, P> {
723723
Err(WriteError::Io(e)) => {
724724
#[cfg(feature = "log")]
725725
log::error!(target: "reactor", "Fatal error writing to transport {id}, disconnecting. Error details: {e:?}");
726-
self.unregister_transport(id);
726+
if let Some(transport) = self.unregister_transport(id) {
727+
return Err(Error::TransportDisconnect(id, transport));
728+
}
727729
}
728730
Ok(_) => {}
729731
}

0 commit comments

Comments
 (0)