diff --git a/app/src/async_stream.py b/app/src/async_stream.py
index fd25489..a09a67e 100644
--- a/app/src/async_stream.py
+++ b/app/src/async_stream.py
@@ -99,6 +99,11 @@ class AsyncStream(Message):
                     f"{traceback.format_exc()}")
                 self.close()
                 return
+            
+    def disc(self) -> None:
+        logger.debug(f'in AsyncStream.disc() {self.addr}')
+        self.writer.close()
+            
         
     def close(self) -> None:
         logger.debug(f'in AsyncStream.close() {self.addr}')