pub struct ObjectReader { /* private fields */ }Expand description
Streaming reader returned by S3::read_object and Object::stream.
Implementations§
Source§impl ObjectReader
impl ObjectReader
Sourcepub fn meta(&self) -> &ObjectMeta
pub fn meta(&self) -> &ObjectMeta
Returns the metadata frame emitted at the start of the stream.
Sourcepub async fn next_chunk(&mut self) -> Result<Option<Vec<u8>>, S3Error>
pub async fn next_chunk(&mut self) -> Result<Option<Vec<u8>>, S3Error>
Returns the next non-empty body chunk.
Sourcepub async fn bytes(self) -> Result<Vec<u8>, S3Error>
pub async fn bytes(self) -> Result<Vec<u8>, S3Error>
Reads the remainder of the stream into memory.
Sourcepub async fn text(self) -> Result<String, S3Error>
pub async fn text(self) -> Result<String, S3Error>
Reads the remainder of the stream as UTF-8 text.
Sourcepub async fn json<T>(self) -> Result<T, S3Error>where
T: DeserializeOwned,
pub async fn json<T>(self) -> Result<T, S3Error>where
T: DeserializeOwned,
Reads and decodes the remainder of the stream as JSON.
Auto Trait Implementations§
impl Freeze for ObjectReader
impl !RefUnwindSafe for ObjectReader
impl Send for ObjectReader
impl Sync for ObjectReader
impl Unpin for ObjectReader
impl UnsafeUnpin for ObjectReader
impl !UnwindSafe for ObjectReader
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request