(self)
| 88 | self.assertEqual(messages, observer.data) |
| 89 | |
| 90 | def test_map_multiple_updates(self): |
| 91 | observable = self.create_observable() |
| 92 | mapped_observable = observable.map(lambda chunk: chunk + '_x') |
| 93 | |
| 94 | observer, messages = self._test_multiple_updates(observable, mapped_observable) |
| 95 | messages = [m + '_x' for m in messages] |
| 96 | |
| 97 | self.assertEqual(messages, observer.data) |
| 98 | |
| 99 | def test_time_buffer_multiple_updates(self): |
| 100 | observable = self.create_observable() |
nothing calls this directly
no test coverage detected