From deb784d68dd15d34e2eb6dc4c4d7b6c50ccb1610 Mon Sep 17 00:00:00 2001 From: draoi Date: Sat, 27 Jan 2024 17:46:48 +0100 Subject: [PATCH] channel: use convenience function --- src/net/channel.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/net/channel.rs b/src/net/channel.rs index f646132d5..f072e0eca 100644 --- a/src/net/channel.rs +++ b/src/net/channel.rs @@ -150,7 +150,7 @@ impl Channel { pub async fn subscribe_stop(&self) -> Result> { debug!(target: "net::channel::subscribe_stop()", "START {:?}", self); - if self.stopped.load(SeqCst) { + if self.is_stopped() { return Err(Error::ChannelStopped) }