while True:
    try:
        return self._sock.recv_into(b)
    except timeout:
        self._timeout_occurred = True
        raise
    except InterruptedError:  // <---------- removed
        continue              // <---------- removed
    except error as e:
        if e.args[0] in _blocking_errnos:
            return None
        raise

while True:
    try:
        return self._sock.recv_into(b)
    except timeout:
        self._timeout_occurred = True
        raise
    except error as e:
        if e.args[0] in _blocking_errnos:
            return None
        raise