Bläddra i källkod

channel: use convenience function

draoi 2 år sedan
förälder
incheckning
deb784d68d
1 ändrade filer med 1 tillägg och 1 borttagningar
  1. 1 1
      src/net/channel.rs

+ 1 - 1
src/net/channel.rs

@@ -150,7 +150,7 @@ impl Channel {
     pub async fn subscribe_stop(&self) -> Result<Subscription<Error>> {
         debug!(target: "net::channel::subscribe_stop()", "START {:?}", self);
 
-        if self.stopped.load(SeqCst) {
+        if self.is_stopped() {
             return Err(Error::ChannelStopped)
         }