(self)
| 34 | self.assertEqual([message], observer.data) |
| 35 | |
| 36 | def test_map_single_update(self): |
| 37 | observable = self.create_observable() |
| 38 | mapped_observable = observable.map(lambda chunk: chunk + '_x') |
| 39 | |
| 40 | observer, message = self._test_single_update(observable, mapped_observable) |
| 41 | self.assertEqual([message + '_x'], observer.data) |
| 42 | |
| 43 | def test_time_buffer_single_update(self): |
| 44 | observable = self.create_observable() |
nothing calls this directly
no test coverage detected