pub fn read_entries_stream<'stream, 'map: 'stream, K: 'map, V: 'map>(
        &'map self,
        max_entries_at_once: i32,
    ) -> impl Stream<Item = Result<(K, V, Version), TableError>> + 'stream
    where
        K: Serialize + serde::de::DeserializeOwned + std::marker::Unpin,
        V: Serialize + serde::de::DeserializeOwned + std::marker::Unpin,
    {
        try_stream! {
            let mut token: Vec<u8> = Vec::new();
            loop {
                let res: (Vec<(Vec<u8>, Vec<u8>,Version)>, Vec<u8>)  = self.read_entries_raw(max_entries_at_once, &token).await?;
                let (entries, t) = res;
                if entries.is_empty() {
                    break;
                } else {
                    for (key_raw, value_raw, version) in entries {
                        let key: K = from_slice(key_raw.as_slice()).expect("error during deserialization");
                        let value: V = from_slice(value_raw.as_slice()).expect("error during deserialization");
                        yield (key, value, version)
                    }
                    token = t;
                }
            }
        }
    }
/// Read entries as an Async Stream. This method deserialized the Key and Value based on the
/// inferred type.
Read entries as an Async Stream. This method deserialized the Key and Value based on the
inferred type.
Read entries as an Async Stream . This method deserialized the Key and Value based on the inferred type .
pub fn read_entries_stream<'stream, 'map: 'stream, K: 'map, V: 'map>(
        &'map self,
        max_entries_at_once: i32,
    ) -> impl Stream<Item = Result<(K, V, Version), TableError>> + 'stream
    where
        K: Serialize + serde::de::DeserializeOwned + std::marker::Unpin,
        V: Serialize + serde::de::DeserializeOwned + std::marker::Unpin,
    {
        try_stream! {
            let mut token: Vec<u8> = Vec::new();
            loop {
                let res: (Vec<(Vec<u8>, Vec<u8>,Version)>, Vec<u8>)  = self.read_entries_raw(max_entries_at_once, &token).await?;
                let (entries, t) = res;
                if entries.is_empty() {
                    break;
                } else {
                    for (key_raw, value_raw, version) in entries {
                        let key: K = from_slice(key_raw.as_slice()).expect("error during deserialization");
                        let value: V = from_slice(value_raw.as_slice()).expect("error during deserialization");
                        yield (key, value, version)
                    }
                    token = t;
                }
            }
        }
    }
pub fn read_entries_stream < ' stream , ' map : ' stream , K : ' map , V : ' map > ( & ' map self , max_entries_at_once : i32 , ) -> impl Stream < Item = Result < ( K , V , Version ) , TableError > > + ' stream where K : Serialize + serde :: de :: DeserializeOwned + std :: marker :: Unpin , V : Serialize + serde :: de :: DeserializeOwned + std :: marker :: Unpin , { try_stream ! { let mut token Vec u8 Vec new ( ) loop { let res ( Vec ( Vec u8 Vec u8 Version ) Vec u8 ) self read_entries_raw ( max_entries_at_once token ) await let ( entries t ) res if entries is_empty ( ) { break } else { for ( key_raw value_raw version ) in entries { let key K from_slice ( key_raw as_slice ( ) ) expect ( " " ) let value V from_slice ( value_raw as_slice ( ) ) expect ( " " ) yield ( key value version ) } token t } } } }
Read entries as an Async Stream.
Read entries as an Async Stream .
&'map self
max_entries_at_once
i32
&'map self
max_entries_at_once
i32