File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change 1
1
# -*- coding: utf-8 -*-
2
2
import logging
3
- import aiogrpc
3
+ from grpc import aio
4
4
5
5
6
6
class AsyncPluginManager :
@@ -26,16 +26,15 @@ async def _connect_backend(self):
26
26
"""
27
27
28
28
#: gRPC channel
29
- self ._channel = aiogrpc .insecure_channel (
30
- "{}:{}" .format (self .host , self .port ),
31
- standalone_pool_for_streaming = True
29
+ self ._channel = aio .insecure_channel (
30
+ "{}:{}" .format (self .host , self .port )
32
31
)
33
32
34
33
logger = logging .getLogger (__name__ )
35
34
logger .addHandler (logging .NullHandler ()) # Avoid errors when user has not configured logging
36
35
37
36
logger .debug ("Waiting for mavsdk_server to be ready..." )
38
- await aiogrpc . channel_ready_future ( self ._channel )
37
+ await self ._channel . channel_ready ( )
39
38
logger .debug ("Connected to mavsdk_server!" )
40
39
41
40
@property
You can’t perform that action at this time.
0 commit comments