kumquat-buildroot/package/python-ws4py/0001-Adjust-ws4py-for-Python-3.7-syntax.patch
Ricardo Martincoski 39424c2899 package: remove numbered subject from patches
As reported by check-package (by calling it directly):
generate your patches with 'git format-patch -N'

Change all affected files using this command:
$ sed 's,^\(Subject: *\[PATCH\)[^]]*,\1,g' \
    -i $(find * -name '*.patch' -type f)

Signed-off-by: Ricardo Martincoski <ricardo.martincoski@gmail.com>
Signed-off-by: Arnout Vandecappelle (Essensium/Mind) <arnout@mind.be>
2021-12-11 20:48:58 +01:00

56 lines
1.9 KiB
Diff

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