summaryrefslogtreecommitdiff
path: root/ext/kv/01_db.ts
diff options
context:
space:
mode:
authorLuca Casonato <hello@lcas.dev>2023-03-30 22:52:31 +0200
committerGitHub <noreply@github.com>2023-03-30 22:52:31 +0200
commit02e01b171f29f4f6c23d738b0756b7d9b7eaa020 (patch)
tree5f6b54bf84c6f0f330cf6519846a8e65ae5a0d9d /ext/kv/01_db.ts
parente888c3f534c6ce9574f1d57e5cc61573a046039e (diff)
fix(dts): improve types for the Deno.KV API (#18510)
Diffstat (limited to 'ext/kv/01_db.ts')
-rw-r--r--ext/kv/01_db.ts18
1 files changed, 9 insertions, 9 deletions
diff --git a/ext/kv/01_db.ts b/ext/kv/01_db.ts
index e0c5335e6..05e9a66d8 100644
--- a/ext/kv/01_db.ts
+++ b/ext/kv/01_db.ts
@@ -75,7 +75,7 @@ class Kv {
async getMany(
keys: Deno.KvKey[],
opts?: { consistency?: Deno.KvConsistencyLevel },
- ): Promise<Deno.KvEntry[]> {
+ ): Promise<Deno.KvEntry<unknown>[]> {
keys = keys.map(convertKey);
const ranges: RawKvEntry[][] = await core.opAsync(
"op_kv_snapshot_read",
@@ -174,7 +174,7 @@ class Kv {
cursor: string | undefined,
reverse: boolean,
consistency: Deno.KvConsistencyLevel,
- ) => Promise<Deno.KvEntry[]> {
+ ) => Promise<Deno.KvEntry<unknown>[]> {
return async (selector, cursor, reverse, consistency) => {
const [entries]: [RawKvEntry[]] = await core.opAsync(
"op_kv_snapshot_read",
@@ -304,7 +304,7 @@ function convertKey(key: Deno.KvKey | Deno.KvKeyPart): Deno.KvKey {
}
}
-function deserializeValue(entry: RawKvEntry): Deno.KvEntry {
+function deserializeValue(entry: RawKvEntry): Deno.KvEntry<unknown> {
const { kind, value } = entry.value;
switch (kind) {
case "v8":
@@ -357,9 +357,9 @@ const AsyncIteratorPrototype = ObjectGetPrototypeOf(AsyncGeneratorPrototype);
const AsyncIterator = AsyncIteratorPrototype.constructor;
class KvListIterator extends AsyncIterator
- implements AsyncIterator<Deno.KvEntry> {
+ implements AsyncIterator<Deno.KvEntry<unknown>> {
#selector: Deno.KvListSelector;
- #entries: Deno.KvEntry[] | null = null;
+ #entries: Deno.KvEntry<unknown>[] | null = null;
#cursorGen: (() => string) | null = null;
#done = false;
#lastBatch = false;
@@ -368,7 +368,7 @@ class KvListIterator extends AsyncIterator
cursor: string | undefined,
reverse: boolean,
consistency: Deno.KvConsistencyLevel,
- ) => Promise<Deno.KvEntry[]>;
+ ) => Promise<Deno.KvEntry<unknown>[]>;
#limit: number | undefined;
#count = 0;
#reverse: boolean;
@@ -388,7 +388,7 @@ class KvListIterator extends AsyncIterator
cursor: string | undefined,
reverse: boolean,
consistency: Deno.KvConsistencyLevel,
- ) => Promise<Deno.KvEntry[]>;
+ ) => Promise<Deno.KvEntry<unknown>[]>;
},
) {
super();
@@ -443,7 +443,7 @@ class KvListIterator extends AsyncIterator
return this.#cursorGen();
}
- async next(): Promise<IteratorResult<Deno.KvEntry>> {
+ async next(): Promise<IteratorResult<Deno.KvEntry<unknown>>> {
// Fused or limit exceeded
if (
this.#done ||
@@ -493,7 +493,7 @@ class KvListIterator extends AsyncIterator
};
}
- [Symbol.asyncIterator](): AsyncIterator<Deno.KvEntry> {
+ [Symbol.asyncIterator](): AsyncIterator<Deno.KvEntry<unknown>> {
return this;
}
}