diff options
author | Max Romanov <max.romanov@nginx.com> | 2020-10-01 23:55:35 +0300 |
---|---|---|
committer | Max Romanov <max.romanov@nginx.com> | 2020-10-01 23:55:35 +0300 |
commit | d97e3a3296db77f6a33ce010a66d2a0b2d4bac49 (patch) | |
tree | 833dd50180cbd5bffe43c71f50b0fdf3bd8e8bc2 /test/python/websockets/mirror | |
parent | c4c2f90c5b532c1ec283d211e0fd50e4538c2a51 (diff) | |
download | unit-d97e3a3296db77f6a33ce010a66d2a0b2d4bac49.tar.gz unit-d97e3a3296db77f6a33ce010a66d2a0b2d4bac49.tar.bz2 |
Tests: added ASGI WebSocket.
Diffstat (limited to 'test/python/websockets/mirror')
-rw-r--r-- | test/python/websockets/mirror/asgi.py | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/test/python/websockets/mirror/asgi.py b/test/python/websockets/mirror/asgi.py new file mode 100644 index 00000000..0f1d9953 --- /dev/null +++ b/test/python/websockets/mirror/asgi.py @@ -0,0 +1,18 @@ +async def application(scope, receive, send): + if scope['type'] == 'websocket': + while True: + m = await receive() + if m['type'] == 'websocket.connect': + await send({ + 'type': 'websocket.accept', + }) + + if m['type'] == 'websocket.receive': + await send({ + 'type': 'websocket.send', + 'bytes': m.get('bytes', None), + 'text': m.get('text', None), + }) + + if m['type'] == 'websocket.disconnect': + break; |