Create a new thread pool for each streaming method of gRPC channel

Artem Trubin · Artem Trubin · commit 5cc274bb5c5f · 2021-10-22T13:13:42.000+03:00
diff --git a/mavsdk/async_plugin_manager.py b/mavsdk/async_plugin_manager.py
@@ -27,7 +27,8 @@ async def _connect_backend(self):
 
         #: gRPC channel
         self._channel = aiogrpc.insecure_channel(
-            "{}:{}".format(self.host, self.port)
+            "{}:{}".format(self.host, self.port),
+            standalone_pool_for_streaming=True
         )
 
         logger = logging.getLogger(__name__)

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,8 @@ async def _connect_backend(self):`
`27`	`27`
`28`	`28`	`#: gRPC channel`
`29`	`29`	`self._channel = aiogrpc.insecure_channel(`
`30`		`- "{}:{}".format(self.host, self.port)`
	`30`	`+ "{}:{}".format(self.host, self.port),`
	`31`	`+ standalone_pool_for_streaming=True`
`31`	`32`	`)`
`32`	`33`
`33`	`34`	`logger = logging.getLogger(__name__)`