| from mod_pywebsocket import common |
| from mod_pywebsocket import stream |
| |
| |
| def web_socket_do_extra_handshake(request): |
| pass |
| |
| |
| def web_socket_transfer_data(request): |
| # pyformat: disable |
| messages_to_send = [['Hello, ', 'world!'], |
| ['', 'Hello, ', '', 'world!', ''], |
| ['', '', ''], |
| [chr(i) for i in xrange(256)]] |
| # pyformat: enable |
| for message_list in messages_to_send: |
| for index, message in enumerate(message_list): |
| # FIXME: Should use better API to send binary messages when |
| # pywebsocket supports it. |
| if index == 0: |
| opcode = common.OPCODE_BINARY |
| else: |
| opcode = common.OPCODE_CONTINUATION |
| if index < len(message_list) - 1: |
| final = 0 |
| else: |
| final = 1 |
| header = stream.create_header(opcode, |
| len(message), final, 0, 0, 0, 0) |
| request.connection.write(header + message) |
