12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- 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 1/1] 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
|