From a8449e8417055651df51fca157b641c7fb04207c Mon Sep 17 00:00:00 2001
From: Stefan Allius <stefan.allius@t-online.de>
Date: Tue, 3 Oct 2023 01:30:06 +0200
Subject: [PATCH] implement disc method

---
 app/src/async_stream.py | 5 +++++
 1 file changed, 5 insertions(+)

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}')