@sockets.route('<STR_LIT>')<EOL>def subscribe(ws):
while ws is not None:<EOL><INDENT>gevent.sleep(<NUM_LIT:0.1>)<EOL>try:<EOL><INDENT>message = ws.receive()  <EOL>if message:<EOL><INDENT>stream.register(ws, message)<EOL><DEDENT><DEDENT>except WebSocketError:<EOL><INDENT>ws = None<EOL><DEDENT><DEDENT>
WebSocket endpoint, used for liveupdates