pub async fn insert_all<K, V>(&self, kvps: Vec<(&K, &V)>, offset: i64) -> Result<Vec<Version>, TableError>
    where
        K: Serialize + serde::de::DeserializeOwned,
        V: Serialize + serde::de::DeserializeOwned,
    {
        let r: Vec<(Vec<u8>, Vec<u8>, Version)> = kvps
            .iter()
            .map(|(k, v)| {
                (
                    to_vec(k).expect("error during serialization."),
                    to_vec(v).expect("error during serialization."),
                    TableKey::KEY_NO_VERSION,
                )
            })
            .collect();
        self.insert_raw_values(r, offset).await
    }
/// Unconditionally insert a new or updates an existing entry for the given keys.
/// Once the update is performed the newer versions are returned.
Unconditionally insert a new or updates an existing entry for the given keys.
Once the update is performed the newer versions are returned.
Unconditionally insert a new or updates an existing entry for the given keys . Once the update is performed the newer versions are returned .
pub async fn insert_all<K, V>(&self, kvps: Vec<(&K, &V)>, offset: i64) -> Result<Vec<Version>, TableError>
    where
        K: Serialize + serde::de::DeserializeOwned,
        V: Serialize + serde::de::DeserializeOwned,
    {
        let r: Vec<(Vec<u8>, Vec<u8>, Version)> = kvps
            .iter()
            .map(|(k, v)| {
                (
                    to_vec(k).expect("error during serialization."),
                    to_vec(v).expect("error during serialization."),
                    TableKey::KEY_NO_VERSION,
                )
            })
            .collect();
        self.insert_raw_values(r, offset).await
    }
pub async fn insert_all < K , V > ( & self , kvps : Vec < ( & K , & V ) > , offset : i64 ) -> Result < Vec < Version > , TableError > where K : Serialize + serde :: de :: DeserializeOwned , V : Serialize + serde :: de :: DeserializeOwned , { let r : Vec < ( Vec < u8 > , Vec < u8 > , Version ) > = kvps . iter ( ) . map ( | ( k , v ) | { ( to_vec ( k ) . expect ( " " ) , to_vec ( v ) . expect ( " " ) , TableKey :: KEY_NO_VERSION , ) } ) . collect ( ) ; self . insert_raw_values ( r , offset ) . await }
Unconditionally insert a new or updates an existing entry for the given keys.
Unconditionally insert a new or updates an existing entry for the given keys .
&self
kvps
Vec<(&K, &V)>
offset
i64
&self
kvps
Vec<(&K, &V)>
offset
i64