def consume_receive_buf(self, l):
    assert(len(self._receive_buf) >= l)
    self._receive_buf = self._receive_buf[l:]
called by client to consume receive buffer
dataset/ETHPy150Open ucb-sts/sts/sts/util/deferred_io.py/DeferredIOWorker.consume_receive_buf