pub async fn read_stream<Count>(
        &self,
        stream_name: impl AsRef<str>,
        options: &ReadStreamOptions,
        count: Count,
    ) -> crate::Result<Count::Selection>
    where
        Count: ToCount,
    {
        let stream = commands::read_stream(
            self.client.clone(),
            options,
            stream_name,
            count.to_count() as u64,
        )
        .await?;

        Ok(count.select(stream).await)
    }
/// Reads events from a given stream. The reading can be done forward and
/// backward.
Reads events from a given stream. The reading can be done forward and
backward.
Reads events from a given stream . The reading can be done forward and backward .
pub async fn read_stream<Count>(
        &self,
        stream_name: impl AsRef<str>,
        options: &ReadStreamOptions,
        count: Count,
    ) -> crate::Result<Count::Selection>
    where
        Count: ToCount,
    {
        let stream = commands::read_stream(
            self.client.clone(),
            options,
            stream_name,
            count.to_count() as u64,
        )
        .await?;
        Ok(count.select(stream).await)
    }
pub async fn read_stream < Count > ( & self , stream_name : impl AsRef < str > , options : & ReadStreamOptions , count : Count , ) -> crate :: Result < Count :: Selection > where Count : ToCount , { let stream = commands :: read_stream ( self . client . clone ( ) , options , stream_name , count . to_count ( ) as u64 , ) . await ? ; Ok ( count . select ( stream ) . await ) }
Reads events from a given stream.
Reads events from a given stream .
&self
stream_name
impl AsRef<str>
options
&ReadStreamOptions
count
Count
&self
stream_name
impl AsRef<str>
options
&ReadStreamOptions
count
Count