aboutsummaryrefslogtreecommitdiff
path: root/src/k2v_util.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/k2v_util.rs')
-rw-r--r--src/k2v_util.rs26
1 files changed, 0 insertions, 26 deletions
diff --git a/src/k2v_util.rs b/src/k2v_util.rs
deleted file mode 100644
index 3cd969b..0000000
--- a/src/k2v_util.rs
+++ /dev/null
@@ -1,26 +0,0 @@
-/*
-use anyhow::Result;
-// ---- UTIL: function to wait for a value to have changed in K2V ----
-
-pub async fn k2v_wait_value_changed(
- k2v: &storage::RowStore,
- key: &storage::RowRef,
-) -> Result<CausalValue> {
- loop {
- if let Some(ct) = prev_ct {
- match k2v.poll_item(pk, sk, ct.clone(), None).await? {
- None => continue,
- Some(cv) => return Ok(cv),
- }
- } else {
- match k2v.read_item(pk, sk).await {
- Err(k2v_client::Error::NotFound) => {
- k2v.insert_item(pk, sk, vec![0u8], None).await?;
- }
- Err(e) => return Err(e.into()),
- Ok(cv) => return Ok(cv),
- }
- }
- }
-}
-*/