Struct FileSource

pub struct FileSource { /* private fields */ }

Implements StreamingSource for a tokio::fs::File.

Example

let payload = tokio::fs::File::open("my-data").await?;
let response = client
    .upload_object("projects/_/buckets/my-bucket", "my-object", payload)
    .send_unbuffered()
    .await?;
println!("response details={response:?}");

Trait Implementations

impl Seek for FileSource

type Error = Error

The error type.

async fn seek(&mut self, offset: u64) -> Result<(), Self::Error>

Resets the stream to start from offset.

impl StreamingSource for FileSource

type Error = Error

The error type.

async fn next(&mut self) -> Option<Result<Bytes, Self::Error>>

Gets the next set of data to upload.

async fn size_hint(&self) -> Result<SizeHint, Self::Error>

An estimate of the upload size.