| import time |
| |
| def main(request, response): |
| response.headers.set(b'Content-Type', b'text/event-stream') |
| response.headers.set(b'Cache-Control', b'no-cache') |
| |
| response.explicit_flush = True |
| response.write_status_headers() |
| |
| while True: |
| response.writer.write(u"data:msg") |
| response.writer.write(u"\n") |
| response.writer.write(u"data: msg") |
| response.writer.write(u"\n\n") |
| |
| response.writer.write(u":") |
| response.writer.write(u"\n") |
| |
| response.writer.write(u"falsefield:msg") |
| response.writer.write(u"\n\n") |
| |
| response.writer.write(u"falsefield:msg") |
| response.writer.write(u"\n") |
| |
| response.writer.write(u"Data:data") |
| response.writer.write(u"\n\n") |
| |
| response.writer.write(u"data") |
| response.writer.write(u"\n\n") |
| |
| response.writer.write(u"data:end") |
| response.writer.write(u"\n\n") |
| |
| response.writer.flush() |
| time.sleep(2) |
