| From dfe6f65b7078315c32cebb727e9c47ead7603475 Mon Sep 17 00:00:00 2001 |
| From: Asaf Kahlon <asafka7@gmail.com> |
| Date: Sun, 13 Oct 2019 16:44:44 +0300 |
| Subject: [PATCH] Adjust ws4py for Python 3.7 syntax |
| |
| Since Python 3.7, "async" has become a keyword and cannot be used. |
| Thus, instead of asyncio.async we will use asyncio.ensure_future. |
| |
| There's also a pull request with this change: |
| https://github.com/Lawouach/WebSocket-for-Python/pull/245 |
| |
| Signed-off-by: Asaf Kahlon <asafka7@gmail.com> |
| --- |
| ws4py/async_websocket.py | 4 ++-- |
| ws4py/server/tulipserver.py | 2 +- |
| 2 files changed, 3 insertions(+), 3 deletions(-) |
| |
| diff --git a/ws4py/async_websocket.py b/ws4py/async_websocket.py |
| index 9e2a4c7..ea296b4 100644 |
| --- a/ws4py/async_websocket.py |
| +++ b/ws4py/async_websocket.py |
| @@ -84,7 +84,7 @@ class WebSocket(_WebSocket): |
| def closeit(): |
| yield from self.proto.writer.drain() |
| self.proto.writer.close() |
| - asyncio.async(closeit()) |
| + asyncio.ensure_future(closeit()) |
| |
| def _write(self, data): |
| """ |
| @@ -94,7 +94,7 @@ class WebSocket(_WebSocket): |
| def sendit(data): |
| self.proto.writer.write(data) |
| yield from self.proto.writer.drain() |
| - asyncio.async(sendit(data)) |
| + asyncio.ensure_future(sendit(data)) |
| |
| @asyncio.coroutine |
| def run(self): |
| diff --git a/ws4py/server/tulipserver.py b/ws4py/server/tulipserver.py |
| index 2786c16..85312a2 100644 |
| --- a/ws4py/server/tulipserver.py |
| +++ b/ws4py/server/tulipserver.py |
| @@ -40,7 +40,7 @@ class WebSocketProtocol(asyncio.StreamReaderProtocol): |
| #self.stream.set_transport(transport) |
| asyncio.StreamReaderProtocol.connection_made(self, transport) |
| # Let make it concurrent for others to tag along |
| - f = asyncio.async(self.handle_initial_handshake()) |
| + f = asyncio.ensure_future(self.handle_initial_handshake()) |
| f.add_done_callback(self.terminated) |
| |
| @property |
| -- |
| 2.20.1 |
| |
