def _make_write_waiter(self, _, exc=None):
        # callback for the after_write event
        if self._paused:
            waiter = self._write_waiter
            assert waiter is None and 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/operator `or` -> `and`