feat: split

README.md

@@ -126,8 +126,10 @@ fromIterable(new Set([1, 2, 3]))
 ```javascript
 import { join } from '@ilteoood/re-flusso/join';
 
+const separator = ',';
+
 .pipeThrough(
-    join('-')
+    join(separator)
 )
 
 ```
@@ -227,6 +229,20 @@ const itemsToSkip = 2;
 ```
 </details>
 
+<details>
+<summary>split</summary>
+
+```javascript
+import { split } from '@ilteoood/re-flusso/split';
+
+const separator = ',';
+
+.pipeTo(
+    split(separator)
+)
+```
+</details>
+
 <details>
 <summary>toArray</summary>
 

src/split.ts

@@ -0,0 +1,15 @@
+export const split = <T>(
+	separator = ",",
+	writableStrategy?: QueuingStrategy,
+	readableStrategy?: QueuingStrategy,
+) => {
+	return new TransformStream<string, string[]>(
+		{
+			transform(chunk, controller) {
+				controller.enqueue(chunk.split(separator));
+			},
+		},
+		writableStrategy,
+		readableStrategy,
+	);
+};

test/join.test.ts

@@ -43,14 +43,16 @@ describe("join", () => {
 		const destinationArray = [];
 
 		await pipeline(
-			fromIterable([{ a: 1, toString: () => "a1" }, { a: 2, toString: () => "a2" }, { a: 3, toString: () => "a3" }]),
+			fromIterable([
+				{ a: 1, toString: () => "a1" },
+				{ a: 2, toString: () => "a2" },
+				{ a: 3, toString: () => "a3" },
+			]),
 			join("-"),
 			toArray(destinationArray),
 		);
 
-		expect(destinationArray).toEqual([
-			"a1-a2-a3",
-		]);
+		expect(destinationArray).toEqual(["a1-a2-a3"]);
 	});
 
 	test("should not throw with arrays", async () => {

test/split.test.ts

@@ -0,0 +1,28 @@
+import { describe, expect, test } from "vitest";
+
+import { fromIterable } from "../src/fromIterable";
+import { pipeline } from "../src/pipeline";
+import { split } from "../src/split";
+import { toArray } from "../src/toArray";
+
+describe("split", () => {
+	test("should split strings", async () => {
+		const destinationArray = [];
+
+		await pipeline(fromIterable(["1,2,3"]), split(), toArray(destinationArray));
+
+		expect(destinationArray).toEqual([["1", "2", "3"]]);
+	});
+
+	test("should split strings with custom separator", async () => {
+		const destinationArray = [];
+
+		await pipeline(
+			fromIterable(["1-2-3"]),
+			split("-"),
+			toArray(destinationArray),
+		);
+
+		expect(destinationArray).toEqual([["1", "2", "3"]]);
+	});
+});