diff --git a/src/connection/connection.js b/src/connection/connection.js
index d1ff248..2127117 100644
--- a/src/connection/connection.js
+++ b/src/connection/connection.js
@@ -209,6 +209,8 @@ class Connection {
    * @return {Promise<void>}
    */
   async close () {
+    this.streams.map(s => s.close && s.close())
+    
     if (this.stat.status === Status.CLOSED) {
       return
     }