diff --git a/radicle-node/src/wire/protocol.rs b/radicle-node/src/wire/protocol.rs index dae781c3..2cb446ba 100644 --- a/radicle-node/src/wire/protocol.rs +++ b/radicle-node/src/wire/protocol.rs @@ -574,7 +574,7 @@ where log::debug!(target: "wire", "Received stream close command for id={stream} from {nid}"); if let Some(chans) = streams.unregister(&stream) { - chans.send(ChannelEvent::Close).ok(); + chans.close().ok(); } } Ok(Some(Frame {