diff options
| author | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-11-02 15:28:19 +0100 |
|---|---|---|
| committer | Quentin Dufour <quentin@deuxfleurs.fr> | 2023-11-02 15:28:19 +0100 |
| commit | a65f5b25894faa9802d274beb394f40062c65bae (patch) | |
| tree | 990e3f3cb1a9d9eb3bbaa62bc16049ef9524d6e6 /src/k2v_util.rs | |
| parent | 1e192f93d5bf544c82fe91fb799d77e8b5d53afe (diff) | |
| download | aerogramme-a65f5b25894faa9802d274beb394f40062c65bae.tar.gz aerogramme-a65f5b25894faa9802d274beb394f40062c65bae.zip | |
WIP rewrite mail/incoming
Diffstat (limited to 'src/k2v_util.rs')
| -rw-r--r-- | src/k2v_util.rs | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/src/k2v_util.rs b/src/k2v_util.rs index 9dadab4..3cd969b 100644 --- a/src/k2v_util.rs +++ b/src/k2v_util.rs @@ -1,14 +1,10 @@ +/* use anyhow::Result; - -use k2v_client::{CausalValue, CausalityToken, K2vClient}; - // ---- UTIL: function to wait for a value to have changed in K2V ---- pub async fn k2v_wait_value_changed( - k2v: &K2vClient, - pk: &str, - sk: &str, - prev_ct: &Option<CausalityToken>, + k2v: &storage::RowStore, + key: &storage::RowRef, ) -> Result<CausalValue> { loop { if let Some(ct) = prev_ct { @@ -27,3 +23,4 @@ pub async fn k2v_wait_value_changed( } } } +*/ |