diff options
| author | Igor Zinkovsky <igor@deno.com> | 2023-09-26 20:06:57 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-09-26 20:06:57 -0700 |
| commit | f0a022bed4c8ca46c472c6361f1793cb29f73480 (patch) | |
| tree | 4f88ffcd77e94292a8696111ba6828a197eb153e /ext/kv/interface.rs | |
| parent | b433133a1ff1c329b05ce024d8db5fefb8f7b431 (diff) | |
fix(kv_queues): graceful shutdown (#20627)
This fixes the `TypeError: Database closed` error during shutdown.
Diffstat (limited to 'ext/kv/interface.rs')
| -rw-r--r-- | ext/kv/interface.rs | 2 |
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); } |