Struct aws_smithy_http::event_stream::Receiver

pub struct Receiver<T, E> { /* fields omitted */ }

Receives Smithy-modeled messages out of an Event Stream.

Implementations

impl<T, E> Receiver<T, E>

pub fn new(
    unmarshaller: impl UnmarshallMessage<Output = T, Error = E> + Send + 'static,
    body: SdkBody
) -> Self

Creates a new Receiver with the given message unmarshaller and SDK body.

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

Asynchronously tries to receive a message 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 Receiver<T, E>

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

Formats the value using the given formatter.