Method wait_close

src/react/observable.py:80–84

(self, timeout=None)

        return _ReplayPipe(self)

    def wait_close(self, timeout=None):
        if (timeout is not None) and (timeout > 0):
            self._wait_close_timed(timeout)
        else:
            self._wait_close_unlimited()

    def _wait_close_unlimited(self):
        with self.close_condition: