chore: publish on jsr

jsr.json

@@ -0,0 +1,5 @@
+{
+  "name": "@bowencool/async-utilities",
+  "version": "2.5.5",
+  "exports": "./packages/index.ts"
+}

package.json

@@ -116,7 +116,7 @@
   "description": "async utilities",
   "author": "bowencool",
   "name": "@bowencool/async-utilities",
-  "version": "2.5.4",
+  "version": "2.5.5",
   "gitHooks": {
     "pre-commit": "lint-staged && jest --onlyChanged --coverage",
     "post-merge": "jest --changedFilesWithAncestor --coverage",

packages/abortableAsync/index.ts

@@ -10,7 +10,10 @@ export type AbortableOption = {
   // alwaysPendingWhenTimeout?: boolean;
 };
 
-export function abortableAsync<T, P extends any[], R>(fn: (this: T, ...p: P) => Promise<R>, opt: AbortableOption = {}) {
+export function abortableAsync<T, P extends any[], R>(
+  fn: (this: T, ...p: P) => Promise<R>,
+  opt: AbortableOption = {},
+): (this: T, ...p: P) => Promise<R> {
   return function abortabledAsync(this: T, ...args: P): Promise<R> {
     return new Promise((resolve, reject) => {
       let timer: ReturnType<typeof setTimeout> | undefined;

packages/concurrentAsync/index.ts

@@ -1,4 +1,7 @@
-export function concurrentAsync<T, P extends any[], R>(fn: (this: T, ...p: P) => Promise<R>, maxCount = 3) {
+export function concurrentAsync<T, P extends any[], R>(
+  fn: (this: T, ...p: P) => Promise<R>,
+  maxCount = 3,
+): (this: T, ...p: P) => Promise<R> {
   let that: T;
 
   type Resolve = (arg: R) => void;

packages/debounceAsync/index.ts

@@ -1,4 +1,7 @@
-export function debounceAsync<T, P extends any[], R>(fn: (this: T, ...p: P) => Promise<R>, ms: number = 300) {
+export function debounceAsync<T, P extends any[], R>(
+  fn: (this: T, ...p: P) => Promise<R>,
+  ms: number = 300,
+): (this: T, ...p: P) => Promise<R> {
   let timeoutId: ReturnType<typeof setTimeout>;
   return function debouncedFiltered(this: T, ...args: P): Promise<R> {
     return new Promise((resolve, reject) => {

packages/debounceAsyncResult/index.ts

@@ -1,4 +1,6 @@
-export function debounceAsyncResult<T, P extends any[], R>(fn: (this: T, ...p: P) => Promise<R>) {
+export function debounceAsyncResult<T, P extends any[], R>(
+  fn: (this: T, ...p: P) => Promise<R>,
+): (this: T, ...p: P) => Promise<R> {
   let lastFetchId = 0;
   return function asyncDebounced(this: T, ...args: P): Promise<R> {
     const fetchId = ++lastFetchId;

packages/throttleAsyncResult/index.ts

@@ -1,7 +1,7 @@
 export function throttleAsyncResult<T, P extends any[], R>(
   fn: (this: T, ...p: P) => Promise<R>,
   { useSamePromise = false } = {},
-) {
+): (this: T, ...p: P) => Promise<R> {
   let isPending = false;
   let theLastPromise: null | Promise<R> = null;
   return function asyncThrottled(this: T, ...args: P): Promise<R> {

packages/withRetryAsync/index.ts

@@ -14,7 +14,7 @@ export function withRetryAsync<T, P extends any[], R>(
      */
     onFailed = (i: number, lastFailedReason: unknown[]) => {},
   } = {},
-) {
+): (this: T, ...p: P) => Promise<R> {
   return function withRetryedAsync(this: T, ...args: P): Promise<R> {
     return new Promise((resolve, reject) => {
       let retriedCount = 0;

readme.md

@@ -40,3 +40,7 @@ import { throttleAsyncResult } from '@bowencool/async-utilities';
 
 - ~~cacheAsync~~ see [memoizee](https://github.com/medikoo/memoizee#memoizing-asynchronous-functions) or [lru-pcache](https://github.com/jmendiara/lru-pcache)
 - [ ] abort fetch & xhr
+
+## License
+
+MIT

tsconfig.json

@@ -6,6 +6,7 @@
     "skipLibCheck": true,
     "noImplicitThis": true,
     "noImplicitAny": true,
+    "noImplicitReturns": true,
     "jsx": "preserve",
     "importHelpers": true,
     "moduleResolution": "node",