

def _wakeup_waiter(self, _, exc=None):
    if (not self._paused):
        return
    self.resume_writing(exc=exc)

dataset/ETHPy150Open quantmind/pulsar/pulsar/async/mixins.py FlowControl._wakeup_waiter/original