Struct surrealml_core::storage::stream_adapter::StreamAdapter

pub struct StreamAdapter { /* private fields */ }

Stream adapter for file system.

Arguments

• chunk_size - The size of the chunks to read from the file.
• file_pointer - The pointer to the file to be streamed

Implementations

impl StreamAdapter

pub fn new(chunk_size: usize, file_path: String) -> Result<Self, SurrealError>

Creates a new StreamAdapter struct.

Arguments

• chunk_size - The size of the chunks to read from the file.
• file_path - The path to the file to be streamed

Returns

A new StreamAdapter struct.

Trait Implementations

impl Stream for StreamAdapter

fn poll_next( self: Pin<&mut Self>, _cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>

Polls the next chunk from the file.

Arguments

• self - The StreamAdapter struct.
• cx - The context of the task to enable the task to be woken up and polled again using the waker.

Returns

A poll containing the next chunk from the file.

type Item = Result<Bytes, Box<dyn Error + Send + Sync>>

Values yielded by the stream.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.