test: pLimit

src/lib/pLimit.ts

@@ -9,11 +9,6 @@ type AnyFunction = (...arguments_: readonly any[]) => unknown
 const sleep = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms))
 
 export type LimitFunction = {
-	/**
-	 * The number of queued items waiting to be executed.
-	 */
-	readonly queueSize: number
-
 	/**
 	 * @param fn - Promise-returning/async function.
 	 * @param arguments - Any arguments to pass through to `fn`. Support for
@@ -97,16 +92,8 @@ export const pLimit = ({
 		})()
 	}
 
-	const generator = (function_: AnyFunction, ...arguments_: unknown[]) =>
-		new Promise((resolve) => {
+	return ((function_: AnyFunction, ...arguments_: unknown[]) =>
+		new Promise<unknown>((resolve) => {
 			enqueue(function_, resolve, arguments_)
-		})
-
-	Object.defineProperties(generator, {
-		queueSize: {
-			get: () => queue.length,
-		},
-	})
-
-	return generator as LimitFunction
+		})) as LimitFunction
 }

test/writeClient-createAsset.test.ts

@@ -243,3 +243,19 @@ it.concurrent("respects unknown rate limit", async (ctx) => {
 
 	expect(Date.now() - start).toBeGreaterThanOrEqual(UNKNOWN_RATE_LIMIT_DELAY)
 })
+
+it("throws fetch errors as-is", async (ctx) => {
+	const client = createTestWriteClient({
+		ctx,
+		clientConfig: {
+			fetch: () => {
+				throw new Error(ctx.task.name)
+			},
+		},
+	})
+
+	await expect(() =>
+		// @ts-expect-error - testing purposes
+		client.createAsset("foo", "foo.png"),
+	).rejects.toThrowError(ctx.task.name)
+})

test/writeClient-createAssetTag.test.ts

@@ -130,3 +130,19 @@ it.concurrent("respects unknown rate limit", async (ctx) => {
 
 	expect(Date.now() - start).toBeGreaterThanOrEqual(UNKNOWN_RATE_LIMIT_DELAY)
 })
+
+it("throws fetch errors as-is", async (ctx) => {
+	const client = createTestWriteClient({
+		ctx,
+		clientConfig: {
+			fetch: () => {
+				throw new Error(ctx.task.name)
+			},
+		},
+	})
+
+	await expect(() =>
+		// @ts-expect-error - testing purposes
+		client.createAssetTag("foo"),
+	).rejects.toThrowError(ctx.task.name)
+})

test/writeClient-createDocument.test.ts

@@ -127,3 +127,27 @@ it.concurrent("respects unknown rate limit", async (ctx) => {
 
 	expect(Date.now() - start).toBeGreaterThanOrEqual(UNKNOWN_RATE_LIMIT_DELAY)
 })
+
+it("throws fetch errors as-is", async (ctx) => {
+	const client = createTestWriteClient({
+		ctx,
+		clientConfig: {
+			fetch: () => {
+				throw new Error(ctx.task.name)
+			},
+		},
+	})
+
+	await expect(() =>
+		// @ts-expect-error - testing purposes
+		client.createDocument(
+			{
+				type: "type",
+				uid: "uid",
+				lang: "lang",
+				data: {},
+			},
+			"Foo",
+		),
+	).rejects.toThrowError(ctx.task.name)
+})

test/writeClient-updateDocument.test.ts

@@ -144,3 +144,22 @@ it.concurrent("supports custom headers", async (ctx) => {
 		.resolves.toBeUndefined()
 	ctx.expect.assertions(2)
 })
+
+it("throws fetch errors as-is", async (ctx) => {
+	const client = createTestWriteClient({
+		ctx,
+		clientConfig: {
+			fetch: () => {
+				throw new Error(ctx.task.name)
+			},
+		},
+	})
+
+	await expect(() =>
+		// @ts-expect-error - testing purposes
+		client.updateDocument("foo", {
+			uid: "uid",
+			data: {},
+		}),
+	).rejects.toThrowError(ctx.task.name)
+})