(self)
| 117 | assert exc_info.value.stream is stream |
| 118 | |
| 119 | def test_write(self): |
| 120 | messages = [] |
| 121 | stream = JsonMemoryStream([], messages) |
| 122 | for message in self.MESSAGES: |
| 123 | stream.write_json(message) |
| 124 | assert messages == self.MESSAGES |
| 125 | |
| 126 | |
| 127 | class MessageHandlerRecorder(list): |
nothing calls this directly
no test coverage detected