chore: add wait closed placeholder

This makes the compat server transport compatible with asyncio.
hivesolutions · May 3, 2024 · 473e395 · 473e395
1 parent b3bd6af
commit 473e395
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/netius/base/transport.py b/src/netius/base/transport.py
@@ -383,6 +383,10 @@ def serve_forever(self):
         coroutine = self._serve_forever()
         return asynchronous.coroutine_return(coroutine)
 
+    def wait_closed(self):
+        coroutine = self._wait_closed()
+        return asynchronous.coroutine_return(coroutine)
+
     def is_serving(self):
         return True
 
@@ -439,6 +443,11 @@ def _serve_forever(self):
         future = self._loop.create_future()
         yield future
 
+    def _wait_closed(self):
+        future = self._loop.create_future()
+        future.set_result(None)
+        yield future
+
     def _aenter(self):
         try:
             future = self._loop.create_future()