@cspell/cspell-pipe - npm Package Compare versions

Comparing version 6.6.1 to 6.7.0

dist/helpers/index.d.ts

 export { toAsyncIterable } from './toAsyncIterable';
 export { isAsyncIterable } from './util';
 export { toArray } from './toArray';
+export { toDistributableIterable } from './distribute';
+export { interleave } from './interleave';
 //# sourceMappingURL=index.d.ts.map

dist/helpers/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.toArray = exports.isAsyncIterable = exports.toAsyncIterable = void 0;
+exports.interleave = exports.toDistributableIterable = exports.toArray = exports.isAsyncIterable = exports.toAsyncIterable = void 0;
 var toAsyncIterable_1 = require("./toAsyncIterable");
@@ -10,2 +10,6 @@ Object.defineProperty(exports, "toAsyncIterable", { enumerable: true, get: function () { return toAsyncIterable_1.toAsyncIterable; } });
 Object.defineProperty(exports, "toArray", { enumerable: true, get: function () { return toArray_1.toArray; } });
+var distribute_1 = require("./distribute");
+Object.defineProperty(exports, "toDistributableIterable", { enumerable: true, get: function () { return distribute_1.toDistributableIterable; } });
+var interleave_1 = require("./interleave");
+Object.defineProperty(exports, "interleave", { enumerable: true, get: function () { return interleave_1.interleave; } });
 //# sourceMappingURL=index.js.map

dist/index.d.ts

 import * as _helpers from './helpers';
 import * as _operators from './operators';
-export { isAsyncIterable, toArray, toAsyncIterable } from './helpers';
-export { opAwaitAsync, opConcatMap, opFilter, opFlatten, opJoinStrings, opMap, opSkip, opTake, opTap, opUnique, } from './operators';
+export { interleave, isAsyncIterable, toArray, toAsyncIterable, toDistributableIterable } from './helpers';
+export { opAppend, opAwaitAsync, opConcatMap, opFilter, opFlatten, opJoinStrings, opMap, opSkip, opTake, opTap, opUnique, } from './operators';
 export { pipeAsync, pipeSync } from './pipe';
@@ -6,0 +6,0 @@ export declare const operators: typeof _operators;

dist/index.js

@@ -26,10 +26,13 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.helpers = exports.operators = exports.pipeSync = exports.pipeAsync = exports.opUnique = exports.opTap = exports.opTake = exports.opSkip = exports.opMap = exports.opJoinStrings = exports.opFlatten = exports.opFilter = exports.opConcatMap = exports.opAwaitAsync = exports.toAsyncIterable = exports.toArray = exports.isAsyncIterable = void 0;
+exports.helpers = exports.operators = exports.pipeSync = exports.pipeAsync = exports.opUnique = exports.opTap = exports.opTake = exports.opSkip = exports.opMap = exports.opJoinStrings = exports.opFlatten = exports.opFilter = exports.opConcatMap = exports.opAwaitAsync = exports.opAppend = exports.toDistributableIterable = exports.toAsyncIterable = exports.toArray = exports.isAsyncIterable = exports.interleave = void 0;
 const _helpers = __importStar(require("./helpers"));
 const _operators = __importStar(require("./operators"));
 var helpers_1 = require("./helpers");
+Object.defineProperty(exports, "interleave", { enumerable: true, get: function () { return helpers_1.interleave; } });
 Object.defineProperty(exports, "isAsyncIterable", { enumerable: true, get: function () { return helpers_1.isAsyncIterable; } });
 Object.defineProperty(exports, "toArray", { enumerable: true, get: function () { return helpers_1.toArray; } });
 Object.defineProperty(exports, "toAsyncIterable", { enumerable: true, get: function () { return helpers_1.toAsyncIterable; } });
+Object.defineProperty(exports, "toDistributableIterable", { enumerable: true, get: function () { return helpers_1.toDistributableIterable; } });
 var operators_1 = require("./operators");
+Object.defineProperty(exports, "opAppend", { enumerable: true, get: function () { return operators_1.opAppend; } });
 Object.defineProperty(exports, "opAwaitAsync", { enumerable: true, get: function () { return operators_1.opAwaitAsync; } });
@@ -36,0 +39,0 @@ Object.defineProperty(exports, "opConcatMap", { enumerable: true, get: function () { return operators_1.opConcatMap; } });

dist/operators/index.d.ts

@@ -0,1 +1,2 @@
+export { opAppend, opAppendAsync, opAppendSync } from './append';
 export { opAwaitAsync } from './await';
@@ -2,0 +3,0 @@ export { opConcatMap, opConcatMapAsync, opConcatMapSync } from './concatMap';

dist/operators/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.opUniqueSync = exports.opUniqueAsync = exports.opUnique = exports.opTapSync = exports.opTapAsync = exports.opTap = exports.opTakeSync = exports.opTakeAsync = exports.opTake = exports.opSkipSync = exports.opSkipAsync = exports.opSkip = exports.opMapSync = exports.opMapAsync = exports.opMap = exports.opJoinStringsSync = exports.opJoinStringsAsync = exports.opJoinStrings = exports.opFlattenSync = exports.opFlattenAsync = exports.opFlatten = exports.opFilterSync = exports.opFilterAsync = exports.opFilter = exports.opConcatMapSync = exports.opConcatMapAsync = exports.opConcatMap = exports.opAwaitAsync = void 0;
+exports.opUniqueSync = exports.opUniqueAsync = exports.opUnique = exports.opTapSync = exports.opTapAsync = exports.opTap = exports.opTakeSync = exports.opTakeAsync = exports.opTake = exports.opSkipSync = exports.opSkipAsync = exports.opSkip = exports.opMapSync = exports.opMapAsync = exports.opMap = exports.opJoinStringsSync = exports.opJoinStringsAsync = exports.opJoinStrings = exports.opFlattenSync = exports.opFlattenAsync = exports.opFlatten = exports.opFilterSync = exports.opFilterAsync = exports.opFilter = exports.opConcatMapSync = exports.opConcatMapAsync = exports.opConcatMap = exports.opAwaitAsync = exports.opAppendSync = exports.opAppendAsync = exports.opAppend = void 0;
+var append_1 = require("./append");
+Object.defineProperty(exports, "opAppend", { enumerable: true, get: function () { return append_1.opAppend; } });
+Object.defineProperty(exports, "opAppendAsync", { enumerable: true, get: function () { return append_1.opAppendAsync; } });
+Object.defineProperty(exports, "opAppendSync", { enumerable: true, get: function () { return append_1.opAppendSync; } });
 var await_1 = require("./await");
@@ -5,0 +9,0 @@ Object.defineProperty(exports, "opAwaitAsync", { enumerable: true, get: function () { return await_1.opAwaitAsync; } });

dist/operators/joinStrings.js

@@ -26,4 +26,4 @@ "use strict";
 exports.opJoinStringsSync = opJoinStringsSync;
-const opJoinStrings = (joinCharacter = ',') => (0, util_1.toPipeFn)(opJoinStringsSync(joinCharacter), opJoinStringsAsync(joinCharacter));
+const opJoinStrings = (joinCharacter) => (0, util_1.toPipeFn)(opJoinStringsSync(joinCharacter), opJoinStringsAsync(joinCharacter));
 exports.opJoinStrings = opJoinStrings;
 //# sourceMappingURL=joinStrings.js.map

dist/operators/take.d.ts

 export declare function opTakeAsync<T>(count: number): (iter: AsyncIterable<T> | Iterable<T>) => AsyncIterable<T>;
 export declare function opTakeSync<T>(count: number): (iter: Iterable<T>) => Iterable<T>;
+/**
+ * Consume only the first `count` number from the iterable.
+ * @param count - number to take
+ */
 export declare const opTake: <T>(count: number) => import("../internalTypes").PipeFn<T, T>;
 //# sourceMappingURL=take.d.ts.map

dist/operators/take.js

@@ -31,4 +31,8 @@ "use strict";
 exports.opTakeSync = opTakeSync;
+/**
+ * Consume only the first `count` number from the iterable.
+ * @param count - number to take
+ */
 const opTake = (count) => (0, util_1.toPipeFn)(opTakeSync(count), opTakeAsync(count));
 exports.opTake = opTake;
 //# sourceMappingURL=take.js.map

package.json

@@ -6,3 +6,3 @@ {
   },
-  "version": "6.6.1",
+  "version": "6.7.0",
   "description": "Library to make working with Iterators/AsyncIterators easier.",
@@ -97,7 +97,7 @@ "keywords": [
   "devDependencies": {
-    "@types/node": "^18.6.5",
+    "@types/node": "^18.7.6",
     "jest": "^28.1.3",
     "rimraf": "^3.0.2"
   },
-  "gitHead": "3c9c24d1cebd558ac3729d3fbf441e6ed751d8cf"
+  "gitHead": "3a7312a15d2df1507d9e01863ec5842f5a99e0cc"
 }

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

41573

increased by17.3%

Number of package files

45

increased by15.38%

Lines of code

749

increased by24.42%

Worsened metrics

Published versions last months

7

decreased by-22.22%

No dependency changes