@rimbu/stream - npm Package Compare versions

Comparing version 0.10.9 to 0.10.10

dist/main/async-custom/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 var tslib_1 = require("tslib");
-(0, tslib_1.__exportStar)(require("./constructors"), exports);
-(0, tslib_1.__exportStar)(require("./utils"), exports);
-(0, tslib_1.__exportStar)(require("./async-fast-iterator-base"), exports);
-(0, tslib_1.__exportStar)(require("./async-stream-custom"), exports);
+tslib_1.__exportStar(require("./constructors"), exports);
+tslib_1.__exportStar(require("./utils"), exports);
+tslib_1.__exportStar(require("./async-fast-iterator-base"), exports);
+tslib_1.__exportStar(require("./async-stream-custom"), exports);
 //# sourceMappingURL=index.js.map

dist/main/async-custom/utils.js

@@ -10,4 +10,4 @@ "use strict";
     }
-    return (0, tslib_1.__awaiter)(this, void 0, void 0, function () {
-        return (0, tslib_1.__generator)(this, function (_a) {
+    return tslib_1.__awaiter(this, void 0, void 0, function () {
+        return tslib_1.__generator(this, function (_a) {
             switch (_a.label) {
@@ -14,0 +14,0 @@ case 0: return [4 /*yield*/, Promise.all(iters.map(function (i) {

dist/main/async/index.js

@@ -11,7 +11,7 @@ "use strict";
 var tslib_1 = require("tslib");
-(0, tslib_1.__exportStar)(require("./async-stream-source"), exports);
-(0, tslib_1.__exportStar)(require("./async-fast-iterator"), exports);
-(0, tslib_1.__exportStar)(require("./async-fast-iterable"), exports);
-(0, tslib_1.__exportStar)(require("./async-streamable"), exports);
-(0, tslib_1.__exportStar)(require("./interface"), exports);
+tslib_1.__exportStar(require("./async-stream-source"), exports);
+tslib_1.__exportStar(require("./async-fast-iterator"), exports);
+tslib_1.__exportStar(require("./async-fast-iterable"), exports);
+tslib_1.__exportStar(require("./async-streamable"), exports);
+tslib_1.__exportStar(require("./interface"), exports);
 //# sourceMappingURL=index.js.map

dist/main/custom/fast-iterator-custom.js

@@ -42,3 +42,3 @@ "use strict";
 var FlatMapIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FlatMapIterator, _super);
+    tslib_1.__extends(FlatMapIterator, _super);
     function FlatMapIterator(source, flatMapFun) {
@@ -59,3 +59,3 @@ var _this = _super.call(this) || this;
         var done = Symbol('Done');
-        var nextValue = done;
+        var nextValue;
         while (null === this.currentIterator ||
@@ -77,3 +77,3 @@ done === (nextValue = this.currentIterator.fastNext(done))) {
 var ConcatIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ConcatIterator, _super);
+    tslib_1.__extends(ConcatIterator, _super);
     function ConcatIterator(source, otherSources) {
@@ -108,3 +108,3 @@ var _this = _super.call(this) || this;
 var FilterIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FilterIterator, _super);
+    tslib_1.__extends(FilterIterator, _super);
     function FilterIterator(source, pred, invert) {
@@ -145,3 +145,3 @@ var _this = _super.call(this) || this;
 var FilterPureIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FilterPureIterator, _super);
+    tslib_1.__extends(FilterPureIterator, _super);
     function FilterPureIterator(source, pred, args, invert) {
@@ -163,3 +163,3 @@ var _this = _super.call(this) || this;
             while (done !== (value = source.fastNext(done))) {
-                if (!pred.apply(void 0, (0, tslib_1.__spreadArray)([value], (0, tslib_1.__read)(args), false)))
+                if (!pred.apply(void 0, tslib_1.__spreadArray([value], tslib_1.__read(args), false)))
                     return value;
@@ -170,3 +170,3 @@ }
             while (done !== (value = source.fastNext(done))) {
-                if (pred.apply(void 0, (0, tslib_1.__spreadArray)([value], (0, tslib_1.__read)(args), false)))
+                if (pred.apply(void 0, tslib_1.__spreadArray([value], tslib_1.__read(args), false)))
                     return value;
@@ -181,3 +181,3 @@ }
 var CollectIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(CollectIterator, _super);
+    tslib_1.__extends(CollectIterator, _super);
     function CollectIterator(source, collectFun) {
@@ -211,3 +211,3 @@ var _this = _super.call(this) || this;
 var IndicesWhereIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IndicesWhereIterator, _super);
+    tslib_1.__extends(IndicesWhereIterator, _super);
     function IndicesWhereIterator(source, pred) {
@@ -236,3 +236,3 @@ var _this = _super.call(this) || this;
 var IndicesOfIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IndicesOfIterator, _super);
+    tslib_1.__extends(IndicesOfIterator, _super);
     function IndicesOfIterator(source, searchValue, eq) {
@@ -263,3 +263,3 @@ var _this = _super.call(this) || this;
 var TakeWhileIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(TakeWhileIterator, _super);
+    tslib_1.__extends(TakeWhileIterator, _super);
     function TakeWhileIterator(source, pred) {
@@ -291,3 +291,3 @@ var _this = _super.call(this) || this;
 var DropWhileIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(DropWhileIterator, _super);
+    tslib_1.__extends(DropWhileIterator, _super);
     function DropWhileIterator(source, pred) {
@@ -318,3 +318,3 @@ var _this = _super.call(this) || this;
 var TakeIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(TakeIterator, _super);
+    tslib_1.__extends(TakeIterator, _super);
     function TakeIterator(source, amount) {
@@ -336,3 +336,3 @@ var _this = _super.call(this) || this;
 var DropIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(DropIterator, _super);
+    tslib_1.__extends(DropIterator, _super);
     function DropIterator(source, amount) {
@@ -361,3 +361,3 @@ var _this = _super.call(this) || this;
 var RepeatIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(RepeatIterator, _super);
+    tslib_1.__extends(RepeatIterator, _super);
     function RepeatIterator(source, amount) {
@@ -396,3 +396,3 @@ var _this = _super.call(this) || this;
 var IntersperseIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IntersperseIterator, _super);
+    tslib_1.__extends(IntersperseIterator, _super);
     function IntersperseIterator(source, sepStream) {
@@ -439,3 +439,3 @@ var _this = _super.call(this) || this;
 var SplitWhereIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(SplitWhereIterator, _super);
+    tslib_1.__extends(SplitWhereIterator, _super);
     function SplitWhereIterator(source, pred) {
@@ -468,3 +468,3 @@ var _this = _super.call(this) || this;
 var SplitOnIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(SplitOnIterator, _super);
+    tslib_1.__extends(SplitOnIterator, _super);
     function SplitOnIterator(source, sepElem, eq) {
@@ -499,3 +499,3 @@ var _this = _super.call(this) || this;
 var ReduceIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ReduceIterator, _super);
+    tslib_1.__extends(ReduceIterator, _super);
     function ReduceIterator(source, reducer) {
@@ -528,3 +528,3 @@ var _this = _super.call(this) || this;
 var ReduceAllIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ReduceAllIterator, _super);
+    tslib_1.__extends(ReduceAllIterator, _super);
     function ReduceAllIterator(source, reducers) {
@@ -574,3 +574,3 @@ var _this = _super.call(this) || this;
 var ArrayIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ArrayIterator, _super);
+    tslib_1.__extends(ArrayIterator, _super);
     function ArrayIterator(array, startIndex, endIndex) {
@@ -593,3 +593,3 @@ var _this = _super.call(this) || this;
 var ArrayReverseIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ArrayReverseIterator, _super);
+    tslib_1.__extends(ArrayReverseIterator, _super);
     function ArrayReverseIterator(array, startIndex, endIndex) {
@@ -611,3 +611,3 @@ var _this = _super.call(this) || this;
 var AlwaysIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(AlwaysIterator, _super);
+    tslib_1.__extends(AlwaysIterator, _super);
     function AlwaysIterator(value) {
@@ -625,3 +625,3 @@ var _this = _super.call(this) || this;
 var MapApplyIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(MapApplyIterator, _super);
+    tslib_1.__extends(MapApplyIterator, _super);
     function MapApplyIterator(source, f, args) {
@@ -640,3 +640,3 @@ var _this = _super.call(this) || this;
             return (0, common_1.OptLazy)(otherwise);
-        return this.f.apply(this, (0, tslib_1.__spreadArray)((0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(next), false), (0, tslib_1.__read)(args), false));
+        return this.f.apply(this, tslib_1.__spreadArray(tslib_1.__spreadArray([], tslib_1.__read(next), false), tslib_1.__read(args), false));
     };
@@ -647,3 +647,3 @@ return MapApplyIterator;
 var FilterApplyIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FilterApplyIterator, _super);
+    tslib_1.__extends(FilterApplyIterator, _super);
     function FilterApplyIterator(source, pred, args, invert) {
@@ -665,3 +665,3 @@ var _this = _super.call(this) || this;
             while (done !== (next = iter.fastNext(done))) {
-                if (!pred.apply(void 0, (0, tslib_1.__spreadArray)((0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(next), false), (0, tslib_1.__read)(args), false)))
+                if (!pred.apply(void 0, tslib_1.__spreadArray(tslib_1.__spreadArray([], tslib_1.__read(next), false), tslib_1.__read(args), false)))
                     return next;
@@ -672,3 +672,3 @@ }
             while (done !== (next = iter.fastNext(done))) {
-                if (pred.apply(void 0, (0, tslib_1.__spreadArray)((0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(next), false), (0, tslib_1.__read)(args), false)))
+                if (pred.apply(void 0, tslib_1.__spreadArray(tslib_1.__spreadArray([], tslib_1.__read(next), false), tslib_1.__read(args), false)))
                     return next;
@@ -683,3 +683,3 @@ }
 var RangeUpIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(RangeUpIterator, _super);
+    tslib_1.__extends(RangeUpIterator, _super);
     function RangeUpIterator(start, end, delta) {
@@ -708,3 +708,3 @@ if (start === void 0) { start = 0; }
 var RangeDownIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(RangeDownIterator, _super);
+    tslib_1.__extends(RangeDownIterator, _super);
     function RangeDownIterator(start, end, delta) {
@@ -733,3 +733,3 @@ if (start === void 0) { start = 0; }
 var RandomIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(RandomIterator, _super);
+    tslib_1.__extends(RandomIterator, _super);
     function RandomIterator() {
@@ -745,3 +745,3 @@ return _super !== null && _super.apply(this, arguments) || this;
 var RandomIntIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(RandomIntIterator, _super);
+    tslib_1.__extends(RandomIntIterator, _super);
     function RandomIntIterator(min, max) {
@@ -761,3 +761,3 @@ var _this = _super.call(this) || this;
 var UnfoldIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(UnfoldIterator, _super);
+    tslib_1.__extends(UnfoldIterator, _super);
     function UnfoldIterator(init, getNext) {
@@ -788,3 +788,3 @@ var _this = _super.call(this) || this;
 var ZipWithIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ZipWithIterator, _super);
+    tslib_1.__extends(ZipWithIterator, _super);
     function ZipWithIterator(iterables, zipFun) {
@@ -808,3 +808,3 @@ var _this = _super.call(this) || this;
         }
-        return this.zipFun.apply(this, (0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(result), false));
+        return this.zipFun.apply(this, tslib_1.__spreadArray([], tslib_1.__read(result), false));
     };
@@ -815,3 +815,3 @@ return ZipWithIterator;
 var ZipAllWithItererator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ZipAllWithItererator, _super);
+    tslib_1.__extends(ZipAllWithItererator, _super);
     function ZipAllWithItererator(fillValue, iters, zipFun) {
@@ -849,3 +849,3 @@ var _this = _super.call(this) || this;
         }
-        return this.zipFun.apply(this, (0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(result), false));
+        return this.zipFun.apply(this, tslib_1.__spreadArray([], tslib_1.__read(result), false));
     };
@@ -856,3 +856,3 @@ return ZipAllWithItererator;
 var PrependIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(PrependIterator, _super);
+    tslib_1.__extends(PrependIterator, _super);
     function PrependIterator(source, item) {
@@ -875,3 +875,3 @@ var _this = _super.call(this) || this;
 var AppendIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(AppendIterator, _super);
+    tslib_1.__extends(AppendIterator, _super);
     function AppendIterator(source, item) {
@@ -898,3 +898,3 @@ var _this = _super.call(this) || this;
 var IndexedIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IndexedIterator, _super);
+    tslib_1.__extends(IndexedIterator, _super);
     function IndexedIterator(source, startIndex) {
@@ -919,3 +919,3 @@ if (startIndex === void 0) { startIndex = 0; }
 var MapIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(MapIterator, _super);
+    tslib_1.__extends(MapIterator, _super);
     function MapIterator(source, mapFun) {
@@ -942,3 +942,3 @@ var _this = _super.call(this) || this;
 var MapPureIterator = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(MapPureIterator, _super);
+    tslib_1.__extends(MapPureIterator, _super);
     function MapPureIterator(source, mapFun, args) {
@@ -956,3 +956,3 @@ var _this = _super.call(this) || this;
             return (0, common_1.OptLazy)(otherwise);
-        return this.mapFun.apply(this, (0, tslib_1.__spreadArray)([next], (0, tslib_1.__read)(this.args), false));
+        return this.mapFun.apply(this, tslib_1.__spreadArray([next], tslib_1.__read(this.args), false));
     };
@@ -959,0 +959,0 @@ return MapPureIterator;

dist/main/custom/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 var tslib_1 = require("tslib");
-(0, tslib_1.__exportStar)(require("./constructors"), exports);
-(0, tslib_1.__exportStar)(require("./fast-iterator-custom"), exports);
-(0, tslib_1.__exportStar)(require("./stream-custom"), exports);
+tslib_1.__exportStar(require("./constructors"), exports);
+tslib_1.__exportStar(require("./fast-iterator-custom"), exports);
+tslib_1.__exportStar(require("./stream-custom"), exports);
 //# sourceMappingURL=index.js.map

dist/main/custom/stream-custom.js

@@ -61,3 +61,3 @@ "use strict";
         while (done !== (value = iterator.fastNext(done))) {
-            f.apply(void 0, (0, tslib_1.__spreadArray)([value], (0, tslib_1.__read)(args), false));
+            f.apply(void 0, tslib_1.__spreadArray([value], tslib_1.__read(args), false));
         }
@@ -439,3 +439,3 @@ };
 var FromStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FromStream, _super);
+    tslib_1.__extends(FromStream, _super);
     function FromStream(createIterator) {
@@ -452,3 +452,3 @@ var _this = _super.call(this) || this;
 var PrependStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(PrependStream, _super);
+    tslib_1.__extends(PrependStream, _super);
     function PrependStream(source, item) {
@@ -484,3 +484,3 @@ var _this = _super.call(this) || this;
 var AppendStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(AppendStream, _super);
+    tslib_1.__extends(AppendStream, _super);
     function AppendStream(source, item) {
@@ -516,3 +516,3 @@ var _this = _super.call(this) || this;
 var IndexedStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IndexedStream, _super);
+    tslib_1.__extends(IndexedStream, _super);
     function IndexedStream(source, startIndex) {
@@ -533,3 +533,3 @@ var _this = _super.call(this) || this;
 var MapStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(MapStream, _super);
+    tslib_1.__extends(MapStream, _super);
     function MapStream(source, mapFun) {
@@ -577,3 +577,3 @@ var _this = _super.call(this) || this;
 var MapPureStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(MapPureStream, _super);
+    tslib_1.__extends(MapPureStream, _super);
     function MapPureStream(source, mapFun, args) {
@@ -594,3 +594,3 @@ var _this = _super.call(this) || this;
             return (0, common_1.OptLazy)(otherwise);
-        return this.mapFun.apply(this, (0, tslib_1.__spreadArray)([value], (0, tslib_1.__read)(this.args), false));
+        return this.mapFun.apply(this, tslib_1.__spreadArray([value], tslib_1.__read(this.args), false));
     };
@@ -602,3 +602,3 @@ MapPureStream.prototype.last = function (otherwise) {
             return (0, common_1.OptLazy)(otherwise);
-        return this.mapFun.apply(this, (0, tslib_1.__spreadArray)([value], (0, tslib_1.__read)(this.args), false));
+        return this.mapFun.apply(this, tslib_1.__spreadArray([value], tslib_1.__read(this.args), false));
     };
@@ -613,3 +613,3 @@ MapPureStream.prototype.count = function () {
             return (0, common_1.OptLazy)(otherwise);
-        return this.mapFun.apply(this, (0, tslib_1.__spreadArray)([value], (0, tslib_1.__read)(this.args), false));
+        return this.mapFun.apply(this, tslib_1.__spreadArray([value], tslib_1.__read(this.args), false));
     };
@@ -619,3 +619,3 @@ return MapPureStream;
 var FlatMapStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FlatMapStream, _super);
+    tslib_1.__extends(FlatMapStream, _super);
     function FlatMapStream(source, flatmapFun) {
@@ -633,3 +633,3 @@ var _this = _super.call(this) || this;
 var ConcatStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ConcatStream, _super);
+    tslib_1.__extends(ConcatStream, _super);
     function ConcatStream(source, otherSources) {
@@ -709,3 +709,3 @@ var _this = _super.call(this) || this;
 var FilterStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FilterStream, _super);
+    tslib_1.__extends(FilterStream, _super);
     function FilterStream(source, pred, invert) {
@@ -729,3 +729,3 @@ if (invert === void 0) { invert = false; }
 var FilterPureStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FilterPureStream, _super);
+    tslib_1.__extends(FilterPureStream, _super);
     function FilterPureStream(source, pred, args, invert) {
@@ -746,3 +746,3 @@ if (invert === void 0) { invert = false; }
 var CollectStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(CollectStream, _super);
+    tslib_1.__extends(CollectStream, _super);
     function CollectStream(source, collectFun) {
@@ -760,3 +760,3 @@ var _this = _super.call(this) || this;
 var IndicesWhereStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IndicesWhereStream, _super);
+    tslib_1.__extends(IndicesWhereStream, _super);
     function IndicesWhereStream(source, pred) {
@@ -774,3 +774,3 @@ var _this = _super.call(this) || this;
 var IndicesOfStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IndicesOfStream, _super);
+    tslib_1.__extends(IndicesOfStream, _super);
     function IndicesOfStream(source, searchValue, eq) {
@@ -789,3 +789,3 @@ var _this = _super.call(this) || this;
 var TakeWhileStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(TakeWhileStream, _super);
+    tslib_1.__extends(TakeWhileStream, _super);
     function TakeWhileStream(source, pred) {
@@ -803,3 +803,3 @@ var _this = _super.call(this) || this;
 var DropWhileStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(DropWhileStream, _super);
+    tslib_1.__extends(DropWhileStream, _super);
     function DropWhileStream(source, pred) {
@@ -817,3 +817,3 @@ var _this = _super.call(this) || this;
 var TakeStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(TakeStream, _super);
+    tslib_1.__extends(TakeStream, _super);
     function TakeStream(source, amount) {
@@ -836,3 +836,3 @@ var _this = _super.call(this) || this;
 var DropStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(DropStream, _super);
+    tslib_1.__extends(DropStream, _super);
     function DropStream(source, amount) {
@@ -855,3 +855,3 @@ var _this = _super.call(this) || this;
 var IntersperseStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(IntersperseStream, _super);
+    tslib_1.__extends(IntersperseStream, _super);
     function IntersperseStream(source, sepStream) {
@@ -869,3 +869,3 @@ var _this = _super.call(this) || this;
 var SplitWhereStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(SplitWhereStream, _super);
+    tslib_1.__extends(SplitWhereStream, _super);
     function SplitWhereStream(source, pred) {
@@ -883,3 +883,3 @@ var _this = _super.call(this) || this;
 var SplitOnStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(SplitOnStream, _super);
+    tslib_1.__extends(SplitOnStream, _super);
     function SplitOnStream(source, sepElem, eq) {
@@ -898,3 +898,3 @@ var _this = _super.call(this) || this;
 var ReduceStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ReduceStream, _super);
+    tslib_1.__extends(ReduceStream, _super);
     function ReduceStream(source, reducerDef) {
@@ -912,3 +912,3 @@ var _this = _super.call(this) || this;
 var ReduceAllStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ReduceAllStream, _super);
+    tslib_1.__extends(ReduceAllStream, _super);
     function ReduceAllStream(source, reducers) {
@@ -941,3 +941,3 @@ var _this = _super.call(this) || this;
 var FromIterable = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FromIterable, _super);
+    tslib_1.__extends(FromIterable, _super);
     function FromIterable(iterable) {
@@ -958,3 +958,3 @@ var _this = _super.call(this) || this;
 var EmptyStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(EmptyStream, _super);
+    tslib_1.__extends(EmptyStream, _super);
     function EmptyStream() {
@@ -1067,6 +1067,6 @@ return _super !== null && _super.apply(this, arguments) || this;
             return this;
-        var _b = (0, tslib_1.__read)(others), source1 = _b[0], source2 = _b[1], sources = _b.slice(2);
+        var _b = tslib_1.__read(others), source1 = _b[0], source2 = _b[1], sources = _b.slice(2);
         if (undefined === source2)
             return source1;
-        return (_a = (0, exports.fromStreamSource)(source1)).concat.apply(_a, (0, tslib_1.__spreadArray)([source2], (0, tslib_1.__read)(sources), false));
+        return (_a = (0, exports.fromStreamSource)(source1)).concat.apply(_a, tslib_1.__spreadArray([source2], tslib_1.__read(sources), false));
     };
@@ -1129,3 +1129,3 @@ EmptyStream.prototype.min = function (otherwise) {
 var ArrayStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(ArrayStream, _super);
+    tslib_1.__extends(ArrayStream, _super);
     function ArrayStream(array, startIndex, endIndex, reversed) {
@@ -1328,3 +1328,3 @@ if (startIndex === void 0) { startIndex = 0; }
 var AlwaysStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(AlwaysStream, _super);
+    tslib_1.__extends(AlwaysStream, _super);
     function AlwaysStream(value) {
@@ -1379,3 +1379,3 @@ var _this = _super.call(this) || this;
 var MapApplyStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(MapApplyStream, _super);
+    tslib_1.__extends(MapApplyStream, _super);
     function MapApplyStream(source, f, args) {
@@ -1395,3 +1395,3 @@ var _this = _super.call(this) || this;
 var FilterApplyStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(FilterApplyStream, _super);
+    tslib_1.__extends(FilterApplyStream, _super);
     function FilterApplyStream(source, pred, args, invert) {
@@ -1413,3 +1413,3 @@ if (invert === void 0) { invert = false; }
 var RangeStream = /** @class */ (function (_super) {
-    (0, tslib_1.__extends)(RangeStream, _super);
+    tslib_1.__extends(RangeStream, _super);
     function RangeStream(start, end, delta) {
@@ -1492,8 +1492,8 @@ if (delta === void 0) { delta = 1; }
         }
-        var _b = (0, tslib_1.__read)(sources), first = _b[0], rest = _b.slice(1);
+        var _b = tslib_1.__read(sources), first = _b[0], rest = _b.slice(1);
         if (rest.length <= 0) {
             return (0, exports.fromStreamSource)(first);
         }
-        var _c = (0, tslib_1.__read)(rest), rest1 = _c[0], restOther = _c.slice(1);
-        return (_a = (0, exports.fromStreamSource)(first)).concat.apply(_a, (0, tslib_1.__spreadArray)([rest1], (0, tslib_1.__read)(restOther), false));
+        var _c = tslib_1.__read(rest), rest1 = _c[0], restOther = _c.slice(1);
+        return (_a = (0, exports.fromStreamSource)(first)).concat.apply(_a, tslib_1.__spreadArray([rest1], tslib_1.__read(restOther), false));
     },
@@ -1541,3 +1541,3 @@ fromArray: function (array, range, reversed) {
         while (done !== (values = iter.fastNext(done))) {
-            f.apply(void 0, (0, tslib_1.__spreadArray)((0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(values), false), (0, tslib_1.__read)(args), false));
+            f.apply(void 0, tslib_1.__spreadArray(tslib_1.__spreadArray([], tslib_1.__read(values), false), tslib_1.__read(args), false));
         }
@@ -1626,3 +1626,3 @@ },
         }
-        return exports.StreamConstructorsImpl.zipWith.apply(exports.StreamConstructorsImpl, (0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(sources), false))(Array);
+        return exports.StreamConstructorsImpl.zipWith.apply(exports.StreamConstructorsImpl, tslib_1.__spreadArray([], tslib_1.__read(sources), false))(Array);
     },
@@ -1648,3 +1648,3 @@ zipAllWith: function () {
         }
-        return exports.StreamConstructorsImpl.zipAllWith.apply(exports.StreamConstructorsImpl, (0, tslib_1.__spreadArray)([], (0, tslib_1.__read)(sources), false))(fillValue, Array);
+        return exports.StreamConstructorsImpl.zipAllWith.apply(exports.StreamConstructorsImpl, tslib_1.__spreadArray([], tslib_1.__read(sources), false))(fillValue, Array);
     },
@@ -1651,0 +1651,0 @@ flatten: function (source) {

dist/main/main/index.js

@@ -14,8 +14,8 @@ "use strict";
 var tslib_1 = require("tslib");
-(0, tslib_1.__exportStar)(require("./fast-iterator"), exports);
-(0, tslib_1.__exportStar)(require("./fast-iterable"), exports);
-(0, tslib_1.__exportStar)(require("./streamable"), exports);
-(0, tslib_1.__exportStar)(require("./stream-source"), exports);
-(0, tslib_1.__exportStar)(require("./interface"), exports);
-(0, tslib_1.__exportStar)(require("../async"), exports);
+tslib_1.__exportStar(require("./fast-iterator"), exports);
+tslib_1.__exportStar(require("./fast-iterable"), exports);
+tslib_1.__exportStar(require("./streamable"), exports);
+tslib_1.__exportStar(require("./stream-source"), exports);
+tslib_1.__exportStar(require("./interface"), exports);
+tslib_1.__exportStar(require("../async"), exports);
 //# sourceMappingURL=index.js.map

dist/module/async-custom/async-fast-iterator-base.js

@@ -340,3 +340,3 @@ import { __awaiter } from "tslib";
             const done = Symbol('Done');
-            let nextValue = done;
+            let nextValue;
             while (null === this.currentIterator ||
@@ -343,0 +343,0 @@ done === (nextValue = yield this.currentIterator.fastNext(done))) {

dist/module/custom/fast-iterator-custom.js

@@ -47,3 +47,3 @@ import { Token } from '@rimbu/base';
         const done = Symbol('Done');
-        let nextValue = done;
+        let nextValue;
         while (null === this.currentIterator ||
@@ -50,0 +50,0 @@ done === (nextValue = this.currentIterator.fastNext(done))) {

package.json

 {
   "name": "@rimbu/stream",
-  "version": "0.10.9",
+  "version": "0.10.10",
   "description": "Efficient structure representing a sequence of elements, with powerful operations for TypeScript",
@@ -70,5 +70,5 @@ "keywords": [
   "dependencies": {
-    "@rimbu/base": "^0.8.1",
-    "@rimbu/common": "^0.9.1",
-    "tslib": "^2.3.1"
+    "@rimbu/base": "^0.8.2",
+    "@rimbu/common": "^0.9.2",
+    "tslib": "^2.4.0"
   },
@@ -89,3 +89,3 @@ "publishConfig": {
   },
-  "gitHead": "f44e1b43f07ac973555270806bbdde5f06400941"
+  "gitHead": "33dd7ca935f19f513586834a2ce1b1f886352ae7"
 }

README.md

@@ -19,3 +19,3 @@ <p align="center">
 
-For complete documentation please visit the [Stream page](https://rimbu.org/docs/collections/stream) in the _[Rimbu Docs](https://rimbu.org)_.
+For complete documentation please visit the [Stream page](https://rimbu.org/docs/collections/stream) in the _[Rimbu Docs](https://rimbu.org)_, or directly see the _[Rimbu Stream API Docs](https://rimbu.org/api/rimbu/stream)_.
 
@@ -26,3 +26,3 @@ Or [Try Out Rimbu](https://codesandbox.io/s/github/vitoke/rimbu-sandbox/tree/main?previewwindow=console&view=split&editorsize=65&moduleview=1&module=/src/index.ts) in CodeSandBox.
 
-All types are exported through [`@rimbu/core`](../core). It is recommended to use that package.
+For convenience, all main types are also exported through [`@rimbu/core`](../core).
 
@@ -41,26 +41,37 @@ To install separately:
 
-Create a file called `rimbu.ts` and add the following:
+For Deno, the following approach is recommended:
 
-> ```ts
-> export * from 'https://deno.land/x/rimbu/stream/mod.ts';
-> ```
+In the root folder of your project, create or edit a file called `import_map.json` with the following contents (where you should replace `x.y.z` with the desired version of Rimbu):
 
-Or using a pinned version (`x.y.z`):
+```json
+{
+  "imports": {
+    "@rimbu/": "https://deno.land/x/rimbu@x.y.z/"
+  }
+}
+```
 
-> ```ts
-> export * from 'https://deno.land/x/rimbu/stream@x.y.z/mod.ts';
-> ```
+**Note: The trailing slashes are important!**
 
-Then import what you need from `rimbu.ts`:
+In this way you can use relative imports from Rimbu in your code, like so:
 
 ```ts
-import { Stream } from './rimbu.ts';
+import { List } from '@rimbu/core/mod.ts';
+import { HashMap } from '@rimbu/hashed/mod.ts';
 ```
 
-Because Rimbu uses complex types, it's recommended to use the `--no-check` flag (your editor should already have checked your code) and to specify a `tsconfig.json` file with the settings described below.
+Note that for sub-packages, due to conversion limitations it is needed to import the `index.ts` instead of `mod.ts`, like so:
 
-Running your script then becomes:
+```ts
+import { HashMap } from '@rimbu/hashed/map/index.ts';
+```
 
-> `deno run --no-check --config tsconfig.json <your-script>.ts`
+To run your script (let's assume the entry point is in `src/main.ts`):
 
+`deno run --import-map import_map.json src/main.ts`
+
+Because Rimbu uses advanced types, this may slow down the type checking part when running your code. If you're able to rely on your code editor to provide type errors, you can skip the Deno type check using the `--no-check` flag:
+
+`deno run --import-map import_map.json --no-check src/main.ts`
+
 ## Usage
@@ -84,3 +95,3 @@
 
-<img src = "https://contrib.rocks/image?repo=vitoke/iternal"/>
+<img src = "https://contrib.rocks/image?repo=rimbu-org/rimbu"/>
 
@@ -87,0 +98,0 @@ Made with [contributors-img](https://contrib.rocks).

src/async-custom/async-fast-iterator-base.ts

@@ -480,3 +480,3 @@ import { Token } from '@rimbu/base';
 
-    let nextValue: T2 | typeof done = done;
+    let nextValue: T2 | typeof done;
 
@@ -483,0 +483,0 @@ while (

src/custom/fast-iterator-custom.ts

@@ -71,3 +71,3 @@ import { Token } from '@rimbu/base';
 
-    let nextValue: T2 | typeof done = done;
+    let nextValue: T2 | typeof done;
 
@@ -74,0 +74,0 @@ while (

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

Number of lines in readme file

101

increased by12.22%

Worsened metrics

Total package byte prevSize

1087563

decreased by-0.17%

Lines of code

21408

Dependency changes

• Updated@rimbu/base@^0.8.2

• Updated@rimbu/common@^0.9.2

• Updatedtslib@^2.4.0