(_dummy_socket)
| 72 | |
| 73 | |
| 74 | def test_fixture_reader_thread2(_dummy_socket): |
| 75 | sock = _DummySocket() |
| 76 | |
| 77 | reader_thread = ReaderThread(sock) |
| 78 | reader_thread.start() |
| 79 | |
| 80 | json_part = json.dumps({"key": "val"}) |
| 81 | json_part = json_part.replace(":", ":\n") |
| 82 | msg = json_part |
| 83 | |
| 84 | http = "Content-Length: %s\r\n\r\n%s" % (len(msg), msg) |
| 85 | sock.put("msg1\nmsg2\nmsg3\n" + http + http) |
| 86 | |
| 87 | assert reader_thread.get_next_message("check 1") == "msg1" |
| 88 | assert reader_thread.get_next_message("check 2") == "msg2" |
| 89 | assert reader_thread.get_next_message("check 3") == "msg3" |
| 90 | assert reader_thread.get_next_message("check 4") == json_part |
| 91 | assert reader_thread.get_next_message("check 5") == json_part |
| 92 | |
| 93 | |
| 94 | def test_fixture_reader_thread3(_dummy_socket): |
nothing calls this directly
no test coverage detected