Method _test_close

src/tests/observable_test.py:332–342

(self, source, observable, postclose_callback=None)

        self.assertEqual(messages, observer.data)

    def _test_close(self, source, observable, postclose_callback=None):
        observer = _StoringObserver()
        observable.subscribe(observer)

        source.close()

        if postclose_callback:
            postclose_callback()

        self.assertTrue(observer.closed)
        self.assertTrue(observable.closed)

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