@cspell/cspell-pipe - npm Package Compare versions

Comparing version 8.12.1 to 8.13.0

dist/operators/append.js

@@ -8,3 +8,3 @@ import { isAsyncIterable } from '../helpers/index.js';
 export function opAppendAsync(...iterablesToAppend) {
-    async function* fn(iter) {
+    async function* fnAppend(iter) {
         yield* iter;
@@ -15,3 +15,3 @@ for (const i of iterablesToAppend) {
     }
-    return fn;
+    return fnAppend;
 }
@@ -24,3 +24,3 @@ /**
 export function opAppendSync(...iterablesToAppend) {
-    function* fn(iter) {
+    function* fnAppend(iter) {
         yield* iter;
@@ -31,3 +31,3 @@ for (const i of iterablesToAppend) {
     }
-    return fn;
+    return fnAppend;
 }
@@ -34,0 +34,0 @@ export function opAppend(...iterablesToAppend) {

dist/operators/buffer.js

@@ -8,3 +8,3 @@ import { isAsyncIterable } from '../helpers/util.js';
 export function opBufferAsync(size) {
-    async function* fn(iter) {
+    async function* fnBuffer(iter) {
         let buffer = [];
@@ -22,3 +22,3 @@ for await (const v of iter) {
     }
-    return fn;
+    return fnBuffer;
 }
@@ -30,3 +30,3 @@ /**
 export function opBufferSync(size) {
-    function* fn(iter) {
+    function* fnBuffer(iter) {
         let buffer = [];
@@ -44,3 +44,3 @@ for (const v of iter) {
     }
-    return fn;
+    return fnBuffer;
 }
@@ -47,0 +47,0 @@ export function opBuffer(size) {

dist/operators/concatMap.d.ts

 export declare function opConcatMapAsync<T, U = T>(mapFn: (v: T) => AsyncIterable<U> | Iterable<U>): (iter: AsyncIterable<T>) => AsyncIterable<U>;
 export declare function opConcatMapSync<T, U = T>(mapFn: (v: T) => Iterable<U>): (iter: Iterable<T>) => Iterable<U>;
+export declare function _opConcatMapSync<T, U = T>(mapFn: (v: T) => Iterable<U>): (iter: Iterable<T>) => Iterable<U>;
 export declare const opConcatMap: <T, U>(fn: (v: T) => Iterable<U>) => import("../internalTypes.js").PipeFn<T, U>;
 //# sourceMappingURL=concatMap.d.ts.map

dist/operators/concatMap.js

@@ -11,3 +11,34 @@ import { toPipeFn } from '../helpers/util.js';
 export function opConcatMapSync(mapFn) {
-    function* fn(iter) {
+    function fnConcatMapSync(iterable) {
+        function opConcatMapIterator() {
+            const iter = iterable[Symbol.iterator]();
+            let resultsIter = undefined;
+            function nextConcatMap() {
+                while (true) {
+                    if (resultsIter) {
+                        const { done, value } = resultsIter.next();
+                        if (!done) {
+                            return { value };
+                        }
+                        resultsIter = undefined;
+                    }
+                    const { done, value } = iter.next();
+                    if (done) {
+                        return { done, value: undefined };
+                    }
+                    resultsIter = mapFn(value)[Symbol.iterator]();
+                }
+            }
+            return {
+                next: nextConcatMap,
+            };
+        }
+        return {
+            [Symbol.iterator]: opConcatMapIterator,
+        };
+    }
+    return fnConcatMapSync;
+}
+export function _opConcatMapSync(mapFn) {
+    function* fnConcatMapSync(iter) {
         for (const v of iter) {
@@ -17,5 +48,5 @@ yield* mapFn(v);
     }
-    return fn;
+    return fnConcatMapSync;
 }
 export const opConcatMap = (fn) => toPipeFn(opConcatMapSync(fn), opConcatMapAsync(fn));
 //# sourceMappingURL=concatMap.js.map

dist/operators/filter.d.ts

@@ -8,4 +8,6 @@ import type { PipeFn } from '../internalTypes.js';
 export declare function opFilterSync<T>(filterFn: (v: T) => boolean): (iter: Iterable<T>) => Iterable<T>;
+export declare function _opFilterSync<T, S extends T>(filterFn: (v: T) => v is S): (iter: Iterable<T>) => Iterable<S>;
+export declare function _opFilterSync<T>(filterFn: (v: T) => boolean): (iter: Iterable<T>) => Iterable<T>;
 export declare function opFilter<T, S extends T>(fn: (v: T) => v is S): PipeFn<T, S>;
 export declare function opFilter<T>(fn: (v: T) => boolean): PipeFn<T, T>;
 //# sourceMappingURL=filter.d.ts.map

dist/operators/filter.js

 import { isAsyncIterable } from '../helpers/util.js';
 // prettier-ignore
 export function opFilterAsync(filterFn) {
-    async function* fn(iter) {
+    async function* genFilter(iter) {
         for await (const v of iter) {
@@ -11,6 +11,29 @@ const pass = await filterFn(v);
     }
-    return fn;
+    return genFilter;
 }
 export function opFilterSync(filterFn) {
-    function* fn(iter) {
+    function opFilterIterable(iterable) {
+        function opFilterIterator() {
+            const iter = iterable[Symbol.iterator]();
+            function nextOpFilter() {
+                while (true) {
+                    const { done, value } = iter.next();
+                    if (done)
+                        return { done, value: undefined };
+                    if (filterFn(value))
+                        return { value };
+                }
+            }
+            return {
+                next: nextOpFilter,
+            };
+        }
+        return {
+            [Symbol.iterator]: opFilterIterator,
+        };
+    }
+    return opFilterIterable;
+}
+export function _opFilterSync(filterFn) {
+    function* genFilter(iter) {
         for (const v of iter) {
@@ -21,3 +44,3 @@ if (filterFn(v))
     }
-    return fn;
+    return genFilter;
 }
@@ -24,0 +47,0 @@ export function opFilter(fn) {

dist/operators/map.d.ts

 export declare function opMapAsync<T, U = T>(mapFn: (v: T) => U): (iter: AsyncIterable<T>) => AsyncIterable<U>;
-export declare function opMapSync<T, U = T>(mapFn: (v: T) => U): (iter: Iterable<T>) => Iterable<U>;
+export declare function _opMapSync<T, U = T>(mapFn: (v: T) => U): (iter: Iterable<T>) => Iterable<U>;
+export declare function opMapSync<T, U = T>(mapFn: (v: T) => U): (iterable: Iterable<T>) => Iterable<U>;
 export declare const opMap: <T, U>(fn: (v: T) => U) => import("../internalTypes.js").PipeFn<T, U>;
 //# sourceMappingURL=map.d.ts.map

dist/operators/map.js

 import { toPipeFn } from '../helpers/util.js';
 export function opMapAsync(mapFn) {
-    async function* fn(iter) {
+    async function* genMap(iter) {
         for await (const v of iter) {
@@ -8,6 +8,6 @@ yield mapFn(v);
     }
-    return fn;
+    return genMap;
 }
-export function opMapSync(mapFn) {
-    function* fn(iter) {
+export function _opMapSync(mapFn) {
+    function* genMap(iter) {
         for (const v of iter) {
@@ -17,5 +17,25 @@ yield mapFn(v);
     }
-    return fn;
+    return genMap;
 }
+export function opMapSync(mapFn) {
+    function opMapIterable(iterable) {
+        function opMapIterator() {
+            const iter = iterable[Symbol.iterator]();
+            function nextOpMap() {
+                const { done, value } = iter.next();
+                if (done)
+                    return { done, value: undefined };
+                return { value: mapFn(value) };
+            }
+            return {
+                next: nextOpMap,
+            };
+        }
+        return {
+            [Symbol.iterator]: opMapIterator,
+        };
+    }
+    return opMapIterable;
+}
 export const opMap = (fn) => toPipeFn(opMapSync(fn), opMapAsync(fn));
 //# sourceMappingURL=map.js.map

package.json

@@ -6,3 +6,3 @@ {
   },
-  "version": "8.12.1",
+  "version": "8.13.0",
   "description": "Library to make working with Iterators/AsyncIterators easier.",
@@ -103,3 +103,5 @@ "keywords": [
     "!**/*.spec.*",
+    "!**/*.perf.*",
     "!**/*.test.*",
+    "!**/perf/**",
     "!**/test/**",
@@ -109,4 +111,4 @@ "!**/*.map"
   "scripts": {
-    "build": "tsc -b . -f",
-    "watch": "tsc -b . -w -f",
+    "build": "tsc -p .",
+    "watch": "tsc -p . -w",
     "clean": "shx rm -rf dist temp coverage \"*.tsbuildInfo\"",
@@ -116,3 +118,4 @@ "clean-build": "pnpm run clean && pnpm run build",
     "test-watch": "vitest",
-    "test": "vitest run"
+    "test": "vitest run",
+    "test:perf": "NODE_ENV=production insight --register ts-node/esm --file \"**/*.perf.{mts,ts}\""
   },
@@ -131,5 +134,6 @@ "repository": {
   "devDependencies": {
-    "globby": "^14.0.2"
+    "globby": "^14.0.2",
+    "perf-insight": "^1.2.0"
   },
-  "gitHead": "2b9d2fd6fb3a228886016f897c40e8b926e063ab"
+  "gitHead": "2fd3fb430cc96a8a50543f57d96b288219a11923"
 }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

53270

increased by6.09%

Lines of code

1059

increased by7.95%

Worsened metrics

Dev dependency count

2

increased by100%

No dependency changes