Struct AsyncSpillFileReader 

pub struct AsyncSpillFileReader { /* private fields */ }

Async reader for a spill file.

Provides buffered async reading of spill file contents.

Implementations

impl AsyncSpillFileReader

pub async fn read_exact(&mut self, buf: &mut [u8]) -> Result<()>

Reads exactly buf.len() bytes from the file.

Errors

Returns an error if not enough bytes are available.

pub async fn read_u64_le(&mut self) -> Result<u64>

Reads a u64 in little-endian format.

Errors

Returns an error if the read fails.

pub async fn read_i64_le(&mut self) -> Result<i64>

Reads an i64 in little-endian format.

Errors

Returns an error if the read fails.

pub async fn read_f64_le(&mut self) -> Result<f64>

Reads a f64 in little-endian format.

Errors

Returns an error if the read fails.

pub async fn read_u8(&mut self) -> Result<u8>

Reads a u8 byte.

Errors

Returns an error if the read fails.

pub async fn read_bytes(&mut self) -> Result<Vec<u8>>

Reads a length-prefixed byte slice.

Format: [length: u64][data: bytes]

Errors

Returns an error if the read fails.

pub async fn seek(&mut self, pos: SeekFrom) -> Result<u64>

Seeks to a position in the file.

Errors

Returns an error if the seek fails.

pub async fn rewind(&mut self) -> Result<()>

Seeks to the beginning of the file.

Errors

Returns an error if the seek fails.

pub async fn position(&mut self) -> Result<u64>

Returns the current position in the file.

Errors

Returns an error if the operation fails.

Trait Implementations

impl Debug for AsyncSpillFileReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.