async def handle_file_entity(file_entity: FileEntity, stream: AsyncIterator[bytes]) -> FileEntity:
    """Utility function to handle a file entity with its stream.

    This is a convenience function that can be used directly in source implementations.

    Args:
        file_entity: The file entity
        stream: The file stream

    Returns:
        The processed entity
    """
    return await file_manager.handle_file_entity(stream, file_entity)
Utility function to handle a file entity with its stream.

    This is a convenience function that can be used directly in source implementations.

    Args:
        file_entity: The file entity
        stream: The file stream

    Returns:
        The processed entity
    
backend/airweave/platform/file_handling/file_manager.py