(self, method, *args)
| 411 | pass |
| 412 | |
| 413 | def spawn(self, method, *args): |
| 414 | def callback(asyncio_future): |
| 415 | exception = asyncio_future.exception() |
| 416 | if exception is None: |
| 417 | future.resolve(asyncio_future.result()) |
| 418 | else: |
| 419 | future.reject(exception) |
| 420 | future = Future() |
| 421 | task = self.asyncio_loop.create_task(method(*args)) |
| 422 | task.add_done_callback(callback) |
| 423 | return future |
| 424 | |
| 425 | # ----------------------------------------------------------------------- |
| 426 | # WS/PRO code |