@agoric/internal - npm Package Compare versions

Comparing version 0.2.1-dev-fe05415.0 to 0.2.1-pismo-dev-a7455ed.0

package.json

 {
   "name": "@agoric/internal",
-  "version": "0.2.1-dev-fe05415.0+fe05415",
+  "version": "0.2.1-pismo-dev-a7455ed.0+a7455ed",
   "description": "Externally unsupported utilities internal to agoric-sdk",
@@ -37,3 +37,3 @@ "type": "module",
   },
-  "gitHead": "fe054151f0679af87bdf3d3cbb20c0a3a1684f6d"
+  "gitHead": "a7455ed0125e367264dff0cecf24f943e34ce4f0"
 }

src/utils.js

@@ -231,3 +231,3 @@ // @ts-check
  */
-const makeAggregateError = (errors, message) => {
+export const makeAggregateError = (errors, message) => {
   const err = new Error(message);
@@ -283,1 +283,37 @@ Object.defineProperties(err, {
   );
+
+/**
+ * @param {import("fs").ReadStream | import("fs").WriteStream} stream
+ * @returns {Promise<void>}
+ */
+export const fsStreamReady = stream =>
+  new Promise((resolve, reject) => {
+    if (stream.destroyed) {
+      reject(new Error('Stream already destroyed'));
+      return;
+    }
+
+    if (!stream.pending) {
+      resolve();
+      return;
+    }
+
+    const onReady = () => {
+      cleanup(); // eslint-disable-line no-use-before-define
+      resolve();
+    };
+
+    /** @param {Error} err */
+    const onError = err => {
+      cleanup(); // eslint-disable-line no-use-before-define
+      reject(err);
+    };
+
+    const cleanup = () => {
+      stream.off('ready', onReady);
+      stream.off('error', onError);
+    };
+
+    stream.on('ready', onReady);
+    stream.on('error', onError);
+  });

New alerts

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Fixed alerts

Manifest confusion

Supply chain risk

This package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

25154

3.3%

Lines of code

322

10.27%

No dependency changes