📦 @gaubee/util@0.21.0

Author: Gaubee

util/deno.json

@@ -1,6 +1,6 @@
 {
     "name": "@gaubee/util",
-    "version": "0.20.0",
+    "version": "0.21.0",
     "exports": {
         "./abort": "./src/abort.ts",
         "./bigint": "./src/bigint.ts",

util/src/abort.ts

@@ -37,7 +37,9 @@ export const abort_signal_merge = (..._signals: (AbortSignal | undefined | null)
 };
 
 const signal_promise_cache = new Map<AbortSignal, Promise<never>>();
-export const abort_signal_promisify = (input: AbortSignal | { signal: AbortSignal } /*AbortController*/) => {
+export const abort_signal_promisify = (
+    input: AbortSignal | { signal: AbortSignal }, /*AbortController*/
+): Promise<never> => {
     const signal = input instanceof AbortSignal ? input : input.signal;
     return map_get_or_put(signal_promise_cache, signal, () => {
         const job = Promise.withResolvers<never>();

util/src/disposable.ts

@@ -10,13 +10,13 @@ import { PureEvent, PureEventWithApply } from "./pure_event.ts";
 // export const asyncDisposable = new AsyncDisposable();
 
 export class Disposable extends PureEvent<void> {
-    dispose() {
+    dispose(): Promise<void> {
         return this.emit();
     }
-    [Symbol.dispose]() {
+    [Symbol.dispose](): void {
         void this.emit();
     }
-    [Symbol.asyncDispose]() {
+    [Symbol.asyncDispose](): Promise<void> {
         return this.emit();
     }
 }

util/src/promise.ts

@@ -137,7 +137,7 @@ export const promise_once_then = <P extends PromiseLike<any>, T = Awaited<P>>(
 export const promise_once_then_cancel = <P extends PromiseLike<any>, T = Awaited<P>>(
     promise: P,
     task: PromiseOnceThenTask<T>,
-) => {
+): void => {
     const state = _pot.get(promise);
     if (state?.state === "pending") {
         state.tasks.delete(task.key ?? task.resolve ?? task.reject);