Struct aws_sdk_s3::primitives::event_stream::EventReceiver

pub struct EventReceiver<T, E> { /* private fields */ }

Receives unmarshalled events at a time out of an Event Stream.

Implementations

impl<T, E> EventReceiver<T, E>

pub async fn recv(&mut self) -> Result<Option<T>, SdkError<E, RawMessage>>

Asynchronously tries to receive an event from the stream. If the stream has ended, it returns an Ok(None). If there is a transport layer error, it will return Err(SdkError::DispatchFailure). Service-modeled errors will be a part of the returned messages.

Trait Implementations

impl<T: Debug, E: Debug> Debug for EventReceiver<T, E>

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

Formats the value using the given formatter.