fix: don't panic on KV Connect dequeue (#10)

denoland · Oct 30, 2023 · a638dbe · a638dbe
1 parent 14254ca
commit a638dbe
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/remote/lib.rs b/remote/lib.rs
@@ -21,6 +21,7 @@ use denokv_proto::ReadRange;
 use denokv_proto::ReadRangeOutput;
 use denokv_proto::SnapshotReadOptions;
 use log::error;
+use log::warn;
 use rand::Rng;
 use reqwest::StatusCode;
 use serde::Deserialize;
@@ -574,7 +575,8 @@ impl<P: RemotePermissions> Database for Remote<P> {
   async fn dequeue_next_message(
     &self,
   ) -> Result<Option<Self::QMH>, anyhow::Error> {
-    unimplemented!()
+    warn!("KV Connect does not support queues.");
+    std::future::pending().await
   }
 
   fn close(&self) {}