@rimbu/stream - npm Package Compare versions

Comparing version 0.6.1 to 0.7.0

dist/main/fast-iterator.js

@@ -19,3 +19,7 @@ "use strict";
     };
+    function isFastIterator(iterator) {
+        return "fastNext" in iterator;
+    }
+    FastIterator.isFastIterator = isFastIterator;
 })(FastIterator = exports.FastIterator || (exports.FastIterator = {}));
 //# sourceMappingURL=fast-iterator.js.map

dist/main/internal.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.StreamCustom = void 0;
+exports.AsyncStreamCustom = exports.StreamCustom = void 0;
 var tslib_1 = require("tslib");
-exports.StreamCustom = tslib_1.__importStar(require("./stream-custom"));
+exports.StreamCustom = tslib_1.__importStar(require("./stream/stream-custom"));
 tslib_1.__exportStar(require("./fast-iterator"), exports);
 tslib_1.__exportStar(require("./fast-iterable"), exports);
-tslib_1.__exportStar(require("./interface"), exports);
-tslib_1.__exportStar(require("./streamable"), exports);
-tslib_1.__exportStar(require("./stream-source"), exports);
+tslib_1.__exportStar(require("./stream/interface"), exports);
+tslib_1.__exportStar(require("./stream/streamable"), exports);
+tslib_1.__exportStar(require("./stream/stream-source"), exports);
+tslib_1.__exportStar(require("./async-stream/utils"), exports);
+exports.AsyncStreamCustom = tslib_1.__importStar(require("./async-stream/async-stream-custom"));
+tslib_1.__exportStar(require("./async-stream/interface"), exports);
+tslib_1.__exportStar(require("./async-stream/async-fast-iterator"), exports);
+tslib_1.__exportStar(require("./async-stream/async-fast-iterable"), exports);
+tslib_1.__exportStar(require("./async-stream/async-streamable"), exports);
+tslib_1.__exportStar(require("./async-stream/async-stream-source"), exports);
 //# sourceMappingURL=internal.js.map

dist/module/fast-iterator.js

@@ -16,3 +16,7 @@ import { OptLazy } from '@rimbu/common';
     };
+    function isFastIterator(iterator) {
+        return `fastNext` in iterator;
+    }
+    FastIterator.isFastIterator = isFastIterator;
 })(FastIterator || (FastIterator = {}));
 //# sourceMappingURL=fast-iterator.js.map

dist/module/internal.js

@@ -1,7 +0,14 @@
-export * as StreamCustom from './stream-custom';
+export * as StreamCustom from './stream/stream-custom';
 export * from './fast-iterator';
 export * from './fast-iterable';
-export * from './interface';
-export * from './streamable';
-export * from './stream-source';
+export * from './stream/interface';
+export * from './stream/streamable';
+export * from './stream/stream-source';
+export * from './async-stream/utils';
+export * as AsyncStreamCustom from './async-stream/async-stream-custom';
+export * from './async-stream/interface';
+export * from './async-stream/async-fast-iterator';
+export * from './async-stream/async-fast-iterable';
+export * from './async-stream/async-streamable';
+export * from './async-stream/async-stream-source';
 //# sourceMappingURL=internal.js.map

dist/types/fast-iterator.d.ts

@@ -21,2 +21,3 @@ import { OptLazy } from '@rimbu/common';
     const emptyFastIterator: FastIterator<any>;
+    function isFastIterator<T>(iterator: Iterator<T>): iterator is FastIterator<T>;
 }

dist/types/internal.d.ts

@@ -1,6 +0,13 @@
-export * as StreamCustom from './stream-custom';
+export * as StreamCustom from './stream/stream-custom';
 export * from './fast-iterator';
 export * from './fast-iterable';
-export * from './interface';
-export * from './streamable';
-export * from './stream-source';
+export * from './stream/interface';
+export * from './stream/streamable';
+export * from './stream/stream-source';
+export * from './async-stream/utils';
+export * as AsyncStreamCustom from './async-stream/async-stream-custom';
+export * from './async-stream/interface';
+export * from './async-stream/async-fast-iterator';
+export * from './async-stream/async-fast-iterable';
+export * from './async-stream/async-streamable';
+export * from './async-stream/async-stream-source';

package.json

 {
   "name": "@rimbu/stream",
-  "version": "0.6.1",
+  "version": "0.7.0",
   "description": "Efficient structure representing a sequence of elements, with powerful operations for TypeScript",
@@ -50,3 +50,3 @@ "keywords": [
     "bundle:types": "tsc --p tsconfig.types.json",
-    "clean": "rimraf dist deno_dist",
+    "clean": "rimraf dist",
     "format": "yarn format:base --write",
@@ -62,4 +62,4 @@ "format:base": "prettier \"{!CHANGELOG.md}|**/*.{ts,tsx,js,json,md}\"",
   "dependencies": {
-    "@rimbu/base": "^0.6.1",
-    "@rimbu/common": "^0.6.1"
+    "@rimbu/base": "^0.6.2",
+    "@rimbu/common": "^0.7.0"
   },
@@ -72,3 +72,3 @@ "publishConfig": {
   },
-  "gitHead": "ebcf6f5f730b10fd78f14d8886e0b50eb186d5ad"
+  "gitHead": "28453a94283b4f6bcdac1a07737b2bd58ece3658"
 }

src/fast-iterator.ts

@@ -34,2 +34,8 @@ import { OptLazy } from '@rimbu/common';
   };
+
+  export function isFastIterator<T>(
+    iterator: Iterator<T>
+  ): iterator is FastIterator<T> {
+    return `fastNext` in iterator;
+  }
 }

src/internal.ts

@@ -1,7 +0,16 @@
-export * as StreamCustom from './stream-custom';
+export * as StreamCustom from './stream/stream-custom';
 
 export * from './fast-iterator';
 export * from './fast-iterable';
-export * from './interface';
-export * from './streamable';
-export * from './stream-source';
+export * from './stream/interface';
+export * from './stream/streamable';
+export * from './stream/stream-source';
+
+export * from './async-stream/utils';
+export * as AsyncStreamCustom from './async-stream/async-stream-custom';
+
+export * from './async-stream/interface';
+export * from './async-stream/async-fast-iterator';
+export * from './async-stream/async-fast-iterable';
+export * from './async-stream/async-streamable';
+export * from './async-stream/async-stream-source';

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

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

1044538

increased by110.12%

Number of package files

105

increased by84.21%

Lines of code

20145

increased by106.26%

Worsened metrics

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• - Removed@rimbu/common@0.6.1(transitive)

• Updated@rimbu/base@^0.6.2

• Updated@rimbu/common@^0.7.0