Files
nginx-unit/test/python/websockets/mirror/asgi.py
2020-10-01 23:55:35 +03:00

19 lines
591 B
Python

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;