def METHOD_NAME(drain=0):
    try:
        res = select.select(streams, [], [], timeout)
    except OSError as e:
        iflogger.info(e)
        if e.errno == errno.EINTR:
            return
        else:
            raise
    else:
        for stream in res[0]:
            stream.read(drain)