Method closed

common/src/data.rs:91–96

(&self)

    }

    pub async fn closed(&self) {
        trace!("{:?} waiting for channel to close", self);
        while !self.closed.load(Ordering::SeqCst) {
            self.notify.notified().await;
        }
    }
}

impl Debug for DataChannel {