make BlockingPortal.stop sync

src/anyio/from_thread.py

@@ -9,6 +9,7 @@
 from warnings import warn
 
 from ._core import _eventloop
+from ._core._compat import DeprecatedAwaitable
 from ._core._eventloop import get_asynclib, get_cancelled_exc_class, threadlocals
 from ._core._synchronization import Event
 from ._core._tasks import CancelScope, create_task_group
@@ -130,7 +131,7 @@ async def __aenter__(self) -> 'BlockingPortal':
     async def __aexit__(self, exc_type: Optional[Type[BaseException]],
                         exc_val: Optional[BaseException],
                         exc_tb: Optional[TracebackType]) -> Optional[bool]:
-        await self.stop()
+        self.stop()
         return await self._task_group.__aexit__(exc_type, exc_val, exc_tb)
 
     def _check_running(self) -> None:
@@ -143,7 +144,7 @@ async def sleep_until_stopped(self) -> None:
         """Sleep until :meth:`stop` is called."""
         await self._stop_event.wait()
 
-    async def stop(self, cancel_remaining: bool = False) -> None:
+    def stop(self, cancel_remaining: bool = False) -> DeprecatedAwaitable:
         """
         Signal the portal to shut down.
 
@@ -159,6 +160,8 @@ async def stop(self, cancel_remaining: bool = False) -> None:
         if cancel_remaining:
             self._task_group.cancel_scope.cancel()
 
+        return DeprecatedAwaitable(self.stop)
+
     async def _call_func(self, func: Callable, args: tuple, kwargs: Dict[str, Any],
                          future: Future) -> None:
         def callback(f: Future) -> None: