Function ingest_archive 

pub async fn ingest_archive<BE, DS, R>(
    blob_engine: BE,
    directory_service: DS,
    r: R,
) -> Result<Node, IngestionError<Error>>
where
    BE: BlobEngine + Clone + 'static,
    DS: DirectoryService,
    R: AsyncRead + Unpin,

Ingests elements from the archive readable at the passed reader into a the passed BlobEngine and DirectoryService.