diff --git a/sqlx-mysql/src/stream.rs b/sqlx-mysql/src/stream.rs
index a249bc50..340f03d8 100644
--- a/sqlx-mysql/src/stream.rs
+++ b/sqlx-mysql/src/stream.rs
@@ -213,3 +213,13 @@ impl<Rt: Runtime> MySqlStream<Rt> {
         Ok(())
     }
 }
+
+macro_rules! close {
+    (@blocking $self:ident) => {
+        $self.close_blocking()?
+    };
+
+    ($self:ident) => {
+        $self.close_async().await?
+    };
+}