pub async fn stream_item_with_options<T: serde::de::DeserializeOwned>(
        &mut self,
        opts: StreamingOptions,
    ) -> Result<impl Stream<Item = Result<T, StreamError>>, Error> {
        Ok(self.stream_with_options(opts).await?.map(|m| {
            m.map_err(StreamError::Status)
                .and_then(|v: Message| json::from_slice(v.data()).map_err(StreamError::Deserialization))
        }))
    }
/// Stream deserialized values from messages, with options
Stream deserialized values from messages, with options
Stream deserialized values from messages with options
pub async fn stream_item_with_options<T: serde::de::DeserializeOwned>(
        &mut self,
        opts: StreamingOptions,
    ) -> Result<impl Stream<Item = Result<T, StreamError>>, Error> {
        Ok(self.stream_with_options(opts).await?.map(|m| {
            m.map_err(StreamError::Status)
                .and_then(|v: Message| json::from_slice(v.data()).map_err(StreamError::Deserialization))
        }))
    }
pub async fn stream_item_with_options < T : serde :: de :: DeserializeOwned > ( & mut self , opts : StreamingOptions , ) -> Result < impl Stream < Item = Result < T , StreamError > > , Error > { Ok ( self . stream_with_options ( opts ) . await ? . map ( | m | { m . map_err ( StreamError :: Status ) . and_then ( | v : Message | json :: from_slice ( v . data ( ) ) . map_err ( StreamError :: Deserialization ) ) } ) ) }
Stream deserialized values from messages, with options
Stream deserialized values from messages with options
&mut self
opts
StreamingOptions
&mut self
opts
StreamingOptions