@ekino/rendr-sitemap - npm Package Compare versions

Comparing version 0.0.11 to 0.0.12

dist/_bundles/rendr-core.js

@@ -52,3 +52,3 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
         return function (req, res, next) { return __awaiter(_this, void 0, void 0, function () {
-            var iter, sitemapWritable, pageInputStream;
+            var iter, sitemapWritable;
             return __generator(this, function (_a) {
@@ -62,4 +62,3 @@ switch (_a.label) {
                         });
-                        pageInputStream = stream_1.Readable.from(iter);
-                        return [4, pipeline(pageInputStream, sitemapWritable)];
+                        return [4, rendr_core_1.pipeIteratorToWritable(iter, sitemapWritable)];
                     case 1:
@@ -66,0 +65,0 @@ _a.sent();

dist/lib-esm/sitemap.js

@@ -37,4 +37,4 @@ var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
 };
-import { transformGenerator } from "@ekino/rendr-core";
-import { pipeline as StreamPipeline, Writable, Readable } from "stream";
+import { transformGenerator, pipeIteratorToWritable } from "@ekino/rendr-core";
+import { pipeline as StreamPipeline, Writable } from "stream";
 import util from "util";
@@ -45,3 +45,3 @@ var pipeline = util.promisify(StreamPipeline);
     return function (req, res, next) { return __awaiter(_this, void 0, void 0, function () {
-        var iter, sitemapWritable, pageInputStream;
+        var iter, sitemapWritable;
         return __generator(this, function (_a) {
@@ -55,4 +55,3 @@ switch (_a.label) {
                     });
-                    pageInputStream = Readable.from(iter);
-                    return [4, pipeline(pageInputStream, sitemapWritable)];
+                    return [4, pipeIteratorToWritable(iter, sitemapWritable)];
                 case 1:
@@ -59,0 +58,0 @@ _a.sent();

dist/lib/sitemap.js

@@ -49,3 +49,3 @@ "use strict";
     return function (req, res, next) { return __awaiter(_this, void 0, void 0, function () {
-        var iter, sitemapWritable, pageInputStream;
+        var iter, sitemapWritable;
         return __generator(this, function (_a) {
@@ -59,4 +59,3 @@ switch (_a.label) {
                     });
-                    pageInputStream = stream_1.Readable.from(iter);
-                    return [4, pipeline(pageInputStream, sitemapWritable)];
+                    return [4, rendr_core_1.pipeIteratorToWritable(iter, sitemapWritable)];
                 case 1:
@@ -63,0 +62,0 @@ _a.sent();

package.json

 {
     "name": "@ekino/rendr-sitemap",
     "license": "MIT",
-    "version": "0.0.11",
+    "version": "0.0.12",
     "main": "dist/lib/index.js",
@@ -19,7 +19,7 @@ "typing": "dist/lib/index.d.ts",
     "dependencies": {
-        "@ekino/rendr-core": "0.0.11",
-        "@ekino/rendr-loader": "0.0.11",
+        "@ekino/rendr-core": "0.0.12",
+        "@ekino/rendr-loader": "0.0.12",
         "express": "^4.16.4"
     },
-    "gitHead": "af44b9c16767ec2cd956f538cd5c8f27ecf00537"
+    "gitHead": "b98b2ce22a1baff12a5c89262b28464d8701f5b8"
 }

src/sitemap.test.ts

@@ -6,3 +6,4 @@ import {
   AsyncPageReferenceGenerator,
-  StreamCreator
+  StreamCreator,
+  pipeIteratorToWritable
 } from "@ekino/rendr-core";
@@ -12,7 +13,4 @@
 
-import { pipeline as StreamPipeline, Readable, Writable } from "stream";
-import util from "util";
+import { Writable } from "stream";
 
-const pipeline = util.promisify(StreamPipeline);
-
 async function* generatorLoop(i: number): AsyncPageReferenceGenerator {
@@ -64,5 +62,4 @@ for (let x = 0; x < i; x++) {
     });
-    const pageInputStream = Readable.from(iter);
 
-    await pipeline(pageInputStream, sitemapWritable);
+    await pipeIteratorToWritable(iter, sitemapWritable);
 
@@ -102,5 +99,4 @@ expect(files).toMatchSnapshot();
     });
-    const pageInputStream = Readable.from(iter);
 
-    await pipeline(pageInputStream, sitemapWritable);
+    await pipeIteratorToWritable(iter, sitemapWritable);
 
@@ -107,0 +103,0 @@ expect(files).toMatchSnapshot();

src/sitemap.ts

@@ -5,3 +5,4 @@ import {
   PageReferenceGenerator,
-  transformGenerator
+  transformGenerator,
+  pipeIteratorToWritable
 } from "@ekino/rendr-core";
@@ -36,5 +37,4 @@ import { pipeline as StreamPipeline, Writable, Readable } from "stream";
     });
-    const pageInputStream = Readable.from(iter);
 
-    await pipeline(pageInputStream, sitemapWritable);
+    await pipeIteratorToWritable(iter, sitemapWritable);
   };
@@ -41,0 +41,0 @@ }

Fixed alerts

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

Improved metrics

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

45409

decreased by-1.19%

Lines of code

714

decreased by-0.83%

Dependency changes

• + Added@ekino/rendr-core@0.0.12(transitive)

• + Added@ekino/rendr-loader@0.0.12(transitive)

• - Removed@ekino/rendr-core@0.0.11(transitive)

• - Removed@ekino/rendr-loader@0.0.11(transitive)

• Updated@ekino/rendr-core@0.0.12

• Updated@ekino/rendr-loader@0.0.12