Struct sea_streamer_file::AsyncFile

pub struct AsyncFile { /* private fields */ }

A minimal wrapper over async runtime’s File.

Implementations

impl AsyncFile

pub async fn new_r(id: FileId) -> Result<Self, FileErr>

Open a file for Read

pub async fn new_rw(id: FileId) -> Result<Self, FileErr>

Creates a new file for Read/Write. If the file already exsits, read from the beginning. Seek to an appropriate position to append to this file.

pub async fn new_ow(id: FileId) -> Result<Self, FileErr>

Creates a new file for Overwrite. If the file already exists, truncate it.

pub async fn new_w(id: FileId) -> Result<Self, FileErr>

Always create a new file. If the file already exists, abort.

pub async fn read(&mut self) -> Result<Bytes, FileErr>

Read up to BUFFER_SIZE amount of bytes.

pub async fn write_all(&mut self, bytes: &[u8]) -> Result<(), FileErr>

pub async fn flush(&mut self) -> Result<(), FileErr>

pub async fn sync_all(&mut self) -> Result<(), FileErr>

pub async fn seek(&mut self, to: SeqPos) -> Result<u64, FileErr>

Seek the file stream to a different position. SeqNo is regarded as byte offset. Returns the file position after sought.

pub fn id(&self) -> FileId

Get the FileId.

pub fn size(&self) -> u64

Get the file’s size. This updates only when the file is read or sought.

pub fn pos(&self) -> u64

pub async fn resize(&mut self) -> Result<u64, FileErr>

Trait Implementations

impl Drop for AsyncFile

fn drop(&mut self)

Executes the destructor for this type.