Await send_sr (#191)

* Await send_sr * Await ping
aio-libs · Mar 5, 2018 · d1728f0 · d1728f0
1 parent b89a164
commit d1728f0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/sockjs/transports/rawwebsocket.py b/sockjs/transports/rawwebsocket.py
@@ -24,14 +24,14 @@ async def server(self, ws, session):
 
             if frame == FRAME_MESSAGE:
                 for text in data:
-                    ws.send_str(text)
+                    await ws.send_str(text)
             elif frame == FRAME_MESSAGE_BLOB:
                 data = data[1:]
                 if data.startswith('['):
                     data = data[1:-1]
-                ws.send_str(data)
+                await ws.send_str(data)
             elif frame == FRAME_HEARTBEAT:
-                ws.ping()
+                await ws.ping()
             elif frame == FRAME_CLOSE:
                 try:
                     await ws.close(message='Go away!')