Method test_time_buffer_close

src/tests/observable_test.py:355–362

(self)

        self._test_close(observable, mapped_observable)

    def test_time_buffer_close(self):
        observable = self.create_observable()
        buffered_observable = observable.time_buffered(10)

        self._test_close(
            observable,
            buffered_observable,
            lambda: self.wait_buffer_flush(buffered_observable))

    def test_replay_close(self):
        observable = self.create_replay_observable()