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/remote.rs | |
| parent | b433133a1ff1c329b05ce024d8db5fefb8f7b431 (diff) | |
fix(kv_queues): graceful shutdown (#20627)
This fixes the `TypeError: Database closed` error during shutdown.
Diffstat (limited to 'ext/kv/remote.rs')
| -rw-r--r-- | ext/kv/remote.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/ext/kv/remote.rs b/ext/kv/remote.rs index fc18e4615..36c4d3af2 100644 --- a/ext/kv/remote.rs +++ b/ext/kv/remote.rs @@ -277,7 +277,7 @@ impl<P: RemoteDbHandlerPermissions> Database for RemoteDb<P> { async fn dequeue_next_message( &self, _state: Rc<RefCell<OpState>>, - ) -> Result<Self::QMH, AnyError> { + ) -> Result<Option<Self::QMH>, AnyError> { let msg = "Deno.Kv.listenQueue is not supported for remote KV databases"; eprintln!("{}", yellow(msg)); deno_core::futures::future::pending().await |