Method wait_tx_closed

flow-rs/src/channel/storage.rs:153–168

(&self)

    }

    pub async fn wait_tx_closed(&self) {
        let mut listener = None;
        loop {
            if self.is_closed() {
                return;
            }
            match listener.take() {
                None => {
                    listener = Some(self.tx_close_ops.listen());
                }
                Some(l) => {
                    l.await;
                }
            }
        }
    }
}