framework/streams/Stream.test.ts

import Stream from "@framework/streams/Stream";
import { beforeEach, describe, expect, it } from "vitest";

describe("Stream", () => {
    let stream: Stream<number>;

    beforeEach(() => {
        stream = new Stream([1, 2, 3, 4, 5]);
    });

    it("should create a new Stream instance", () => {
        expect(stream).toBeInstanceOf(Stream);
    });

    it("should filter items correctly", () => {
        const filteredStream = stream.filter(item => item > 2);
        expect(Array.from(filteredStream)).toEqual([3, 4, 5]);
    });

    it("should map items correctly", () => {
        const mappedStream = stream.map(item => item * 2);
        expect(Array.from(mappedStream)).toEqual([2, 4, 6, 8, 10]);
    });

    it("should return correct item at index", () => {
        expect(stream.at(2)).toEqual(3);
    });

    it("should concatenate streams correctly", () => {
        const additionalStream = new Stream([6, 7, 8]);
        const concatenatedStream = stream.concat(additionalStream);
        expect(Array.from(concatenatedStream)).toEqual([1, 2, 3, 4, 5, 6, 7, 8]);
    });

    it("should slice streams correctly", () => {
        const slicedStream = stream.slice(1, 3);
        expect(Array.from(slicedStream)).toEqual([2, 3]);
    });

    it("should reduce streams correctly", () => {
        const reducedStream = stream.reduce((acc, item) => acc + item, 0);
        expect(reducedStream.get()).toEqual(15);
    });

    it("should convert to array correctly", () => {
        expect(stream.toArray()).toEqual([1, 2, 3, 4, 5]);
    });
});
1	import Stream from "@framework/streams/Stream";
2	import { beforeEach, describe, expect, it } from "vitest";
3
4	describe("Stream", () => {
5	let stream: Stream<number>;
6
7	beforeEach(() => {
8	stream = new Stream([1, 2, 3, 4, 5]);
9	});
10
11	it("should create a new Stream instance", () => {
12	expect(stream).toBeInstanceOf(Stream);
13	});
14
15	it("should filter items correctly", () => {
16	const filteredStream = stream.filter(item => item > 2);
17	expect(Array.from(filteredStream)).toEqual([3, 4, 5]);
18	});
19
20	it("should map items correctly", () => {
21	const mappedStream = stream.map(item => item * 2);
22	expect(Array.from(mappedStream)).toEqual([2, 4, 6, 8, 10]);
23	});
24
25	it("should return correct item at index", () => {
26	expect(stream.at(2)).toEqual(3);
27	});
28
29	it("should concatenate streams correctly", () => {
30	const additionalStream = new Stream([6, 7, 8]);
31	const concatenatedStream = stream.concat(additionalStream);
32	expect(Array.from(concatenatedStream)).toEqual([1, 2, 3, 4, 5, 6, 7, 8]);
33	});
34
35	it("should slice streams correctly", () => {
36	const slicedStream = stream.slice(1, 3);
37	expect(Array.from(slicedStream)).toEqual([2, 3]);
38	});
39
40	it("should reduce streams correctly", () => {
41	const reducedStream = stream.reduce((acc, item) => acc + item, 0);
42	expect(reducedStream.get()).toEqual(15);
43	});
44
45	it("should convert to array correctly", () => {
46	expect(stream.toArray()).toEqual([1, 2, 3, 4, 5]);
47	});
48	});