

def resume_writing(self, exc=None):
    'Resume writing.\n\n        Successive calls to this method will fails unless\n        :meth:`pause_writing` is called first.\n        '
    assert self._paused
    self._paused = False
    waiter = self._write_waiter
    if (waiter is not None):
        self._write_waiter = None
        if (not waiter.done()):
            if (exc is None):
                waiter.set_result(None)
            else:
                waiter.set_exception(exc)
    self._transport.resume_reading()

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