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

        Ok(count.select(stream).await)
    }
/// Reads events for the system stream `$all`. The reading can be done
/// forward and backward.
Reads events for the system stream `$all`. The reading can be done
forward and backward.
Reads events for the system stream ` $all ` . The reading can be done forward and backward .
pub async fn read_all<Count>(
        &self,
        options: &ReadAllOptions,
        count: Count,
    ) -> crate::Result<Count::Selection>
    where
        Count: ToCount,
    {
        let stream =
            commands::read_all(self.client.clone(), options, count.to_count() as u64).await?;
        Ok(count.select(stream).await)
    }
pub async fn read_all < Count > ( & self , options : & ReadAllOptions , count : Count , ) -> crate :: Result < Count :: Selection > where Count : ToCount , { let stream = commands :: read_all ( self . client . clone ( ) , options , count . to_count ( ) as u64 ) . await ? ; Ok ( count . select ( stream ) . await ) }
Reads events for the system stream `$all`.
Reads events for the system stream ` $all ` .
&self
options
&ReadAllOptions
count
Count
&self
options
&ReadAllOptions
count
Count