summaryrefslogtreecommitdiff
path: root/ext/kv/interface.rs
diff options
context:
space:
mode:
Diffstat (limited to 'ext/kv/interface.rs')
-rw-r--r--ext/kv/interface.rs2
1 files changed, 1 insertions, 1 deletions
diff --git a/ext/kv/interface.rs b/ext/kv/interface.rs
index abeaf8dd5..1acf3ce16 100644
--- a/ext/kv/interface.rs
+++ b/ext/kv/interface.rs
@@ -43,7 +43,7 @@ pub trait Database {
async fn dequeue_next_message(
&self,
state: Rc<RefCell<OpState>>,
- ) -> Result<Self::QMH, AnyError>;
+ ) -> Result<Option<Self::QMH>, AnyError>;
fn close(&self);
}