networkException/netapp
1
0
Fork 0
forked from lx/netapp
Code Pull requests Activity

Remove blocking_send that crashes

Browse source
This commit is contained in:
Alex 2022-07-25 10:58:55 +02:00
parent ab80ade4f0
commit fed0542313
Signed by untrusted user: lx
GPG key ID: 0E496D15096376BE
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/recv.rs
View file

@ -35,7 +35,9 @@ impl Sender {
impl Drop for Sender { impl Drop for Sender {
fn drop(&mut self) { fn drop(&mut self) {
if let Some(inner) = self.inner.take() { if let Some(inner) = self.inner.take() {
let _ = inner.blocking_send(Err(255)); tokio::spawn(async move {
let _ = inner.send(Err(255)).await;
});
} }
} }
} }