Method test_map_close

src/tests/observable_test.py:349–353

(self)

        self._test_close(observable, observable)

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

        self._test_close(observable, mapped_observable)

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