(self, source, observable)
| 19 | self._test_no_updates(observable) |
| 20 | |
| 21 | def _test_single_update(self, source, observable): |
| 22 | observer = _StoringObserver() |
| 23 | observable.subscribe(observer) |
| 24 | |
| 25 | message = 'test notification' |
| 26 | source.push(message) |
| 27 | |
| 28 | return observer, message |
| 29 | |
| 30 | def test_single_update(self): |
| 31 | observable = self.create_observable() |
no test coverage detected