(self)
| 724 | self.assertEqual(late_messages, data) |
| 725 | |
| 726 | def test_map_read_until_closed(self): |
| 727 | observable = self.create_observable() |
| 728 | mapped_observable = observable.map(lambda chunk: chunk + '_x') |
| 729 | |
| 730 | data, _, late_messages = self._test_read_until_closed(observable, mapped_observable) |
| 731 | late_messages = [m + '_x' for m in late_messages] |
| 732 | |
| 733 | self.assertEqual(late_messages, data) |
| 734 | |
| 735 | def test_time_buffer_read_until_closed(self): |
| 736 | observable = self.create_observable() |
nothing calls this directly
no test coverage detected