

def _make_write_waiter(self, _, exc=None):
    if self._paused:
        waiter = self._write_waiter
        assert ((waiter is None) or waiter.cancelled())
        waiter = Future(loop=self._loop)
        self.logger.debug('Waiting for write buffer to drain')
        self._write_waiter = waiter

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