(self)
| 503 | self._test_wait_close(observable, mapped_observable) |
| 504 | |
| 505 | def test_time_buffer_wait_close(self): |
| 506 | observable = self.create_observable() |
| 507 | buffered_observable = observable.time_buffered(10) |
| 508 | |
| 509 | self._test_wait_close(observable, buffered_observable, buffered_observable.wait_close) |
| 510 | |
| 511 | def test_replay_wait_close(self): |
| 512 | observable = self.create_replay_observable() |
nothing calls this directly
no test coverage detected