@@ -629,27 +629,28 @@ def CloseSession(self, nodeid):
629
629
).raise_on_error ()
630
630
631
631
632
- def _establishPASESession (self , callFunct ):
632
+ async def _establishPASESession (self , callFunct ):
633
633
self .CheckIsActive ()
634
634
635
635
with self ._pase_establishment_context as ctx :
636
- self ._ChipStack .Call (callFunct ).raise_on_error ()
637
- ctx .future .result ()
636
+ res = await self ._ChipStack .CallAsync (callFunct )
637
+ res .raise_on_error ()
638
+ await asyncio .futures .wrap_future (ctx .future )
638
639
639
- def EstablishPASESessionBLE (self , setupPinCode : int , discriminator : int , nodeid : int ) -> None :
640
- self ._establishPASESession (
640
+ async def EstablishPASESessionBLE (self , setupPinCode : int , discriminator : int , nodeid : int ) -> None :
641
+ await self ._establishPASESession (
641
642
lambda : self ._dmLib .pychip_DeviceController_EstablishPASESessionBLE (
642
643
self .devCtrl , setupPinCode , discriminator , nodeid )
643
644
)
644
645
645
- def EstablishPASESessionIP (self , ipaddr : str , setupPinCode : int , nodeid : int , port : int = 0 ) -> None :
646
- self ._establishPASESession (
646
+ async def EstablishPASESessionIP (self , ipaddr : str , setupPinCode : int , nodeid : int , port : int = 0 ) -> None :
647
+ await self ._establishPASESession (
647
648
lambda : self ._dmLib .pychip_DeviceController_EstablishPASESessionIP (
648
649
self .devCtrl , ipaddr .encode ("utf-8" ), setupPinCode , nodeid , port )
649
650
)
650
651
651
- def EstablishPASESession (self , setUpCode : str , nodeid : int ) -> None :
652
- self ._establishPASESession (
652
+ async def EstablishPASESession (self , setUpCode : str , nodeid : int ) -> None :
653
+ await self ._establishPASESession (
653
654
lambda : self ._dmLib .pychip_DeviceController_EstablishPASESession (
654
655
self .devCtrl , setUpCode .encode ("utf-8" ), nodeid )
655
656
)
0 commit comments