fix: split

ilteoood · Dec 1, 2023 · 95566bc · 95566bc
1 parent d64728e
commit 95566bc
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 5 deletions.
diff --git a/src/strings/split.ts b/src/strings/split.ts
@@ -3,10 +3,12 @@ export const split = <T>(
 	writableStrategy?: QueuingStrategy,
 	readableStrategy?: QueuingStrategy,
 ) => {
-	return new TransformStream<string, string[]>(
+	return new TransformStream<string, string>(
 		{
 			transform(chunk, controller) {
-				controller.enqueue(chunk.split(separator));
+				for (const item of chunk.split(separator)) {
+					controller.enqueue(item);
+				}
 			},
 		},
 		writableStrategy,

diff --git a/test/strings/split.test.ts b/test/strings/split.test.ts
@@ -11,7 +11,7 @@ describe("split", () => {
 
 		await pipeline(fromIterable(["1,2,3"]), split(), toArray(destinationArray));
 
-		expect(destinationArray).toEqual([["1", "2", "3"]]);
+		expect(destinationArray).toEqual(["1", "2", "3"]);
 	});
 
 	test("should split strings with custom separator", async () => {
@@ -23,6 +23,6 @@ describe("split", () => {
 			toArray(destinationArray),
 		);
 
-		expect(destinationArray).toEqual([["1", "2", "3"]]);
+		expect(destinationArray).toEqual(["1", "2", "3"]);
 	});
 });
diff --git a/tsup.config.ts b/tsup.config.ts
@@ -1,7 +1,7 @@
 import { globSync } from 'glob';
 import { defineConfig } from 'tsup';
 
-const tsFiles = globSync('./src/**/*.ts')
+const tsFiles = globSync('./src/**/*.ts', { posix: true });
 
 export default defineConfig({
     entry: tsFiles,