diff --git a/websock/http/common.nim b/websock/http/common.nim
index fbfcc992e7..b7387b65b4 100644
--- a/websock/http/common.nim
+++ b/websock/http/common.nim
@@ -65,11 +65,15 @@ proc closeWait*(stream: AsyncStream) {.async.} =
   await allFutures(
     stream.reader.closeStream(),
     stream.writer.closeStream(),
+    stream.reader.rsource.closeStream(),
+    stream.writer.wsource.closeStream(),
     stream.reader.tsource.closeTransp())
 
 proc close*(stream: AsyncStream) =
   stream.reader.close()
   stream.writer.close()
+  stream.reader.rsource.close()
+  stream.writer.wsource.close()
   stream.reader.tsource.close()
 
 proc sendResponse*(