diff options
author | Luca Casonato <hello@lcas.dev> | 2023-03-30 22:52:31 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-03-30 22:52:31 +0200 |
commit | 02e01b171f29f4f6c23d738b0756b7d9b7eaa020 (patch) | |
tree | 5f6b54bf84c6f0f330cf6519846a8e65ae5a0d9d /ext/kv/01_db.ts | |
parent | e888c3f534c6ce9574f1d57e5cc61573a046039e (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.ts | 18 |
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; } } |