Testing

Author: mweinelt

adb_shell/adb_device_async.py

@@ -904,8 +904,12 @@ async def streaming_shell(self, command, transport_timeout_s=None, read_timeout_
         if not self.available:
             raise exceptions.AdbConnectionError("ADB command not sent because a connection to the device has not been established.  (Did you call `AdbDeviceAsync.connect()`?)")
 
-        async for line in self._streaming_service(b'shell', command.encode('utf8'), transport_timeout_s, read_timeout_s, decode):
-            yield line
+        agen = self._streaming_service(b'shell', command.encode('utf8'), transport_timeout_s, read_timeout_s, decode)
+        try:
+            async for line in agen:
+                yield line
+        finally:
+            await agen.aclose()
 
     # ======================================================================= #
     #                                                                         #

tests/async_wrapper.py

@@ -1,5 +1,6 @@
 import asyncio
 import warnings
+import sys
 
 
 
@@ -11,6 +12,9 @@ def _await(coro):
         ret = loop.run_until_complete(coro)
         loop.close()
 
+        for warn in warns:
+            print(warn.message, file=sys.stderr)
+
         if warns:
             raise RuntimeError