another drain check

2026-02-25 13:25:47 +01:00
parent 27f0db0c86
commit e5cda2a34f
1 changed files with 3 additions and 0 deletions
@@ -262,6 +262,9 @@ impl TxAsync {
    }

    pub async fn flush(&mut self) -> Result<(), TxOverrunError> {
+        if tx_is_drained(&self.0) {
+            return Ok(());
+        }
        let fut = TxFlushFuture::new(&mut self.0);
        fut.await
    }