rspack_fs 0.100.3

rspack fs
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use std::fmt::Debug;

use rspack_paths::Utf8Path;

use super::Result;
use crate::{Error, WritableFileSystem};

pub trait IntermediateFileSystem:
  WritableFileSystem + IntermediateFileSystemExtras + Debug + Send + Sync
{
}

#[async_trait::async_trait]
pub trait IntermediateFileSystemExtras: Debug + Send + Sync {
  async fn rename(&self, from: &Utf8Path, to: &Utf8Path) -> Result<()>;
  async fn create_read_stream(&self, file: &Utf8Path) -> Result<Box<dyn ReadStream>>;
  async fn create_write_stream(&self, file: &Utf8Path) -> Result<Box<dyn WriteStream>>;
}

#[async_trait::async_trait]
pub trait ReadStream: Debug + Sync + Send {
  async fn read_line(&mut self) -> Result<String> {
    match String::from_utf8(self.read_until(b'\n').await?) {
      Ok(s) => Ok(s),
      Err(_) => Err(Error::Io(std::io::Error::other("invalid utf8 line"))),
    }
  }
  async fn read(&mut self, length: usize) -> Result<Vec<u8>>;
  async fn read_until(&mut self, byte: u8) -> Result<Vec<u8>>;
  async fn read_to_end(&mut self) -> Result<Vec<u8>>;
  async fn skip(&mut self, offset: usize) -> Result<()>;
  async fn close(&mut self) -> Result<()>;
}

#[async_trait::async_trait]
pub trait WriteStream: Debug + Sync + Send {
  async fn write_line(&mut self, line: &str) -> Result<()> {
    self.write(line.as_bytes()).await?;
    self.write(b"\n").await?;
    Ok(())
  }
  async fn write(&mut self, buf: &[u8]) -> Result<usize>;
  async fn write_all(&mut self, buf: &[u8]) -> Result<()>;
  async fn flush(&mut self) -> Result<()>;
  async fn close(&mut self) -> Result<()>;
}