Merge pull request mavlink#398 from atruebin/standalone-pool-for-streaming

JonasVautherin · web-flow · commit 73118a54e103 · 2021-10-22T13:38:53.000+02:00
Create a new thread pool for each streaming method of gRPC channel
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__)`