def pause_writing(self):
        assert not self._paused
        self._paused = True
        self._transport.pause_reading()
Called by the transport when the buffer goes over the
dataset/ETHPy150Open quantmind/pulsar/pulsar/async/mixins.py/FlowControl.pause_writing