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) }