| from mod_pywebsocket import common |
| from mod_pywebsocket import stream |
| |
| |
| def web_socket_do_extra_handshake(request): |
| pass |
| |
| |
| def web_socket_transfer_data(request): |
| payload1 = 'This first text should be received.' |
| payload2 = 'This second text ' |
| payload3 = 'should be received, too.' |
| |
| # send '' |
| request.connection.write(stream.create_header(common.OPCODE_TEXT, |
| 0, |
| 1, 0, 0, 0, 0)) |
| |
| # send payload1 |
| request.connection.write(stream.create_header(common.OPCODE_TEXT, |
| len(payload1), |
| 1, 0, 0, 0, 0) + payload1) |
| |
| # send '' + '' |
| request.connection.write(stream.create_header(common.OPCODE_TEXT, |
| 0, |
| 0, 0, 0, 0, 0)) |
| request.connection.write(stream.create_header(common.OPCODE_CONTINUATION, |
| 0, |
| 1, 0, 0, 0, 0)) |
| |
| # send payload2 + '' + payload3 |
| request.connection.write(stream.create_header(common.OPCODE_TEXT, |
| len(payload2), |
| 0, 0, 0, 0, 0) + payload2) |
| request.connection.write(stream.create_header(common.OPCODE_CONTINUATION, |
| 0, |
| 0, 0, 0, 0, 0)) |
| request.connection.write(stream.create_header(common.OPCODE_CONTINUATION, |
| len(payload3), |
| 1, 0, 0, 0, 0) + payload3) |