def METHOD_NAME(self, _):
    # iterate through a copied list so we can delete from the original
    for key, value in list(self._wait_rx.items()):
        request, stream = value
        if stream.done():
            del self._wait_rx[key]
            log.debug('%s %s', 'removing', req_str(request))
    for key, value in list(self._wait_tx.items()):
        request, stream = value
        if stream.done():
            del self._wait_tx[key]
            log.debug('%s %s', 'removing', req_str(request))
    if not self.is_full:
        self._not_full.set()