Struct zip::tokio::read::ZipArchive

source ·

pub struct ZipArchive<S> { /* private fields */ }

Implementations§

source §

pub async fn by_name( self: Pin<&mut Self>, name: &str ) -> ZipResult<Pin<Box<ZipFile<'_, S, ZipFileWrappedReader<Limiter<S>>>>>>

source

pub async fn by_index( self: Pin<&mut Self>, index: usize ) -> ZipResult<Pin<Box<ZipFile<'_, S, ZipFileWrappedReader<Limiter<S>>>>>>

source

pub async fn by_index_raw( self: Pin<&mut Self>, index: usize ) -> ZipResult<Pin<Box<ZipFile<'_, S, Limiter<S>>>>>

source

pub fn raw_entries_stream( self: Pin<&mut Self> ) -> impl Stream<Item = ZipResult<Pin<Box<ZipFile<'_, S, Limiter<S>>>>>> + '_

source

pub fn entries_stream( self: Pin<&mut Self> ) -> impl Stream<Item = ZipResult<Pin<Box<ZipFile<'_, S, ZipFileWrappedReader<Limiter<S>>>>>>> + '_

source

pub async fn extract_simple( self: Pin<&mut Self>, root: Arc<PathBuf> ) -> ZipResult<()>

 use std::{io::Cursor, pin::Pin, sync::Arc};
 use tokio::{io, fs};

 let buf = {
   use std::io::prelude::*;
   let buf = Cursor::new(Vec::new());
   let mut f = zip::ZipWriter::new(buf);
   let options = zip::write::FileOptions::default()
     .compression_method(zip::CompressionMethod::Deflated);
   f.start_file("a/b.txt", options)?;
   f.write_all(b"hello\n")?;
   f.finish()?
 };
 let mut f = zip::tokio::read::ZipArchive::new(Box::pin(buf)).await?;

 let t = tempfile::tempdir()?;

 let root = t.path();
 Pin::new(&mut f).extract_simple(Arc::new(root.to_path_buf())).await?;
 let msg = fs::read_to_string(root.join("a/b.txt")).await?;
 assert_eq!(&msg, "hello\n");

source

pub async fn extract(self: Pin<&mut Self>, root: Arc<PathBuf>) -> ZipResult<()>

 use std::{io::Cursor, pin::Pin, sync::Arc};
 use tokio::{io, fs};

 let buf = {
   use std::io::prelude::*;
   let buf = Cursor::new(Vec::new());
   let mut f = zip::ZipWriter::new(buf);
   let options = zip::write::FileOptions::default()
     .compression_method(zip::CompressionMethod::Deflated);
   f.start_file("a/b.txt", options)?;
   f.write_all(b"hello\n")?;
   f.finish()?
 };
 let mut f = zip::tokio::read::ZipArchive::new(Box::pin(buf)).await?;

 let t = tempfile::tempdir()?;

 let root = t.path();
 Pin::new(&mut f).extract(Arc::new(root.to_path_buf())).await?;
 let msg = fs::read_to_string(root.join("a/b.txt")).await?;
 assert_eq!(&msg, "hello\n");