Mercurial > libervia-backend

comparison sat/bridge/bridge_constructor/constructors/pb/constructor.py @ 3039:a1bc34f90fa5

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bridge (pb): implemented an asyncio compatible bridge: `pb` bridge can now be used with asyncio by instantiating AIOBridge.
author Goffi <goffi@goffi.org>
date Wed, 25 Sep 2019 08:53:38 +0200
parents ab2696e34d29
children 9d0df638c8b4
comparison
equal deleted inserted replaced
3038:5f3068915686 3039:a1bc34f90fa5
38 {debug}d = self.root.callRemote("{name}"{args_comma}{args_no_def}) 38 {debug}d = self.root.callRemote("{name}"{args_comma}{args_no_def})
39 if callback is not None: 39 if callback is not None:
40 d.addCallback({callback}) 40 d.addCallback({callback})
41 if errback is None: 41 if errback is None:
42 errback = self._generic_errback 42 errback = self._generic_errback
43 d.addErrback(errback)\n""" 43 d.addErrback(errback)\n""",
44 "async_methods": """\
45 def {name}(self{args_comma}{args}):
46 {debug}d = self.root.callRemote("{name}"{args_comma}{args_no_def})
47 d.addErrback(self._errback)
48 return d.asFuture(asyncio.get_event_loop())\n""",
44 } 49 }
45 50
46 def core_completion_signal(self, completion, function, default, arg_doc, async_): 51 def core_completion_signal(self, completion, function, default, arg_doc, async_):
47 completion["args_no_def"] = self.getArguments(function["sig_in"], name=arg_doc) 52 completion["args_no_def"] = self.getArguments(function["sig_in"], name=arg_doc)
48 completion["debug"] = ( 53 completion["debug"] = (