(self, source, observable)
| 71 | self.assertEqual([message], observer.data) |
| 72 | |
| 73 | def _test_multiple_updates(self, source, observable): |
| 74 | observer = _StoringObserver() |
| 75 | observable.subscribe(observer) |
| 76 | |
| 77 | messages = ['m1', '', 'message 3'] |
| 78 | for message in messages: |
| 79 | source.push(message) |
| 80 | |
| 81 | return observer, messages |
| 82 | |
| 83 | def test_multiple_updates(self): |
| 84 | observable = self.create_observable() |
no test coverage detected