Method create_observable

src/tests/observable_test.py:850–853

(self)

        self.assertFalse(thread.is_alive())

    def create_observable(self):
        observable = Observable()
        self._track(observable)
        return observable

    def replay(self, observable):
        replay = observable.replay()