summaryrefslogtreecommitdiff
path: root/ext/kv/sqlite.rs
diff options
context:
space:
mode:
authorMartin Fischer <martin@push-f.com>2023-06-26 15:10:27 +0200
committerGitHub <noreply@github.com>2023-06-26 09:10:27 -0400
commit801b9ec62d94f201e67d053ee90dae0b70e50a42 (patch)
tree145f840c570dd72258ef309e9d31f100a5aa5786 /ext/kv/sqlite.rs
parentad3c494b46c97f0cf91098b7ec2afa576ea7a3dd (diff)
chore: fix typos (#19572)
Diffstat (limited to 'ext/kv/sqlite.rs')
-rw-r--r--ext/kv/sqlite.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/ext/kv/sqlite.rs b/ext/kv/sqlite.rs
index 6cff3145d..808bf9b4f 100644
--- a/ext/kv/sqlite.rs
+++ b/ext/kv/sqlite.rs
@@ -325,7 +325,7 @@ impl SqliteQueue {
// Oneshot requeue of all inflight messages.
Self::requeue_inflight_messages(conn.clone()).await.unwrap();
- // Continous dequeue loop.
+ // Continuous dequeue loop.
Self::dequeue_loop(conn.clone(), dequeue_tx, shutdown_rx, waker_rx)
.await
.unwrap();
@@ -716,12 +716,12 @@ impl Database for SqliteDb {
}
tx.commit()?;
- let new_vesionstamp = version_to_versionstamp(version);
+ let new_versionstamp = version_to_versionstamp(version);
Ok((
has_enqueues,
Some(CommitResult {
- versionstamp: new_vesionstamp,
+ versionstamp: new_versionstamp,
}),
))
})