Mercurial > libervia-backend
diff libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py @ 4270:0d7bb4df2343
Reformatted code base using black.
author | Goffi <goffi@goffi.org> |
---|---|
date | Wed, 19 Jun 2024 18:44:57 +0200 |
parents | 26b7ed2817da |
children |
line wrap: on
line diff
--- a/libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py Tue Jun 18 12:06:45 2024 +0200 +++ b/libervia/backend/bridge/bridge_constructor/constructors/pb/pb_frontend_template.py Wed Jun 19 18:44:57 2024 +0200 @@ -48,9 +48,7 @@ pass else: raise exceptions.InternalError( - "{name} signal handler has been registered twice".format( - name=method_name - ) + "{name} signal handler has been registered twice".format(name=method_name) ) setattr(self, method_name, handler) @@ -70,8 +68,7 @@ """Convert Failure to BridgeException""" ori_errback( BridgeException( - name=failure_.type.decode('utf-8'), - message=str(failure_.value) + name=failure_.type.decode("utf-8"), message=str(failure_.value) ) ) @@ -167,11 +164,13 @@ ##METHODS_PART## + class AIOSignalsHandler(SignalsHandler): def register_signal(self, name, handler, iface="core"): async_handler = lambda *args, **kwargs: defer.Deferred.fromFuture( - asyncio.ensure_future(handler(*args, **kwargs))) + asyncio.ensure_future(handler(*args, **kwargs)) + ) return super().register_signal(name, async_handler, iface) @@ -183,9 +182,8 @@ def _errback(self, failure_): """Convert Failure to BridgeException""" raise BridgeException( - name=failure_.type.decode('utf-8'), - message=str(failure_.value) - ) + name=failure_.type.decode("utf-8"), message=str(failure_.value) + ) def call(self, name, *args, **kwargs): d = self.root.callRemote(name, *args, *kwargs) @@ -196,4 +194,5 @@ d = super().bridge_connect(callback=None, errback=None) return await d.asFuture(asyncio.get_event_loop()) + ##ASYNC_METHODS_PART##