implement disc method

This commit is contained in:
Stefan Allius
2023-10-03 01:30:06 +02:00
parent f097b3350b
commit a8449e8417

View File

@@ -100,6 +100,11 @@ class AsyncStream(Message):
self.close() self.close()
return return
def disc(self) -> None:
logger.debug(f'in AsyncStream.disc() {self.addr}')
self.writer.close()
def close(self) -> None: def close(self) -> None:
logger.debug(f'in AsyncStream.close() {self.addr}') logger.debug(f'in AsyncStream.close() {self.addr}')
super().close() super().close()