feat: fromRange

README.md

@@ -200,6 +200,21 @@ const errorToThrow = new Error('Stream is empty');
 ```
 </details>
 
+<details>
+<summary>numbers</summary>
+
+<details>
+<summary>&nbsp;&nbsp;&nbsp;&nbsp;fromRange</summary>
+
+```javascript
+import { fromRange } from '@ilteoood/re-flusso/numbers/fromRange';
+
+fromRange(1, 3)
+```
+</details>
+</details>
+</details>
+
 <details>
 <summary>pipeline</summary>
 

src/numbers/fromRange.ts

@@ -0,0 +1,20 @@
+export const fromRange = (
+	min: number,
+	max: number,
+	strategy?: QueuingStrategy,
+): ReadableStream<number> => {
+	let currentValue = min;
+	return new ReadableStream<number>(
+		{
+			pull(controller) {
+				if (currentValue <= max) {
+					controller.enqueue(currentValue);
+					currentValue++;
+				} else {
+					controller.close();
+				}
+			},
+		},
+		strategy,
+	);
+};

test/numbers/fromRange.test.ts

@@ -0,0 +1,22 @@
+import { describe, expect, test } from "vitest";
+import { fromRange } from "../../src/numbers/fromRange";
+import { pipeline } from "../../src/pipeline";
+import { toArray } from "../../src/toArray";
+
+describe("fromRange", () => {
+	test("should generate range", async () => {
+		const destinationArray = [];
+
+		await pipeline(fromRange(1, 3), toArray(destinationArray));
+
+		expect(destinationArray).toEqual([1, 2, 3]);
+	});
+
+	test("should generate empty range when min > max", async () => {
+		const destinationArray = [];
+
+		await pipeline(fromRange(3, 1), toArray(destinationArray));
+
+		expect(destinationArray).toEqual([]);
+	});
+});