it("throws if it is called with a single non-function argument", () => {
        expect(() => from([1]).aggregate(1)).toThrowError("`processNext` should be a function");
    });