Method test_map_wait_close

src/tests/observable_test.py:499–503

(self)

        self._test_wait_close(observable, observable)

    def test_map_wait_close(self):
        observable = self.create_observable()
        mapped_observable = observable.map(lambda chunk: chunk + '_x')

        self._test_wait_close(observable, mapped_observable)

    def test_time_buffer_wait_close(self):
        observable = self.create_observable()