unenv - npm Package Compare versions

Comparing version 0.3.5 to 0.3.6

CHANGELOG.md

@@ -5,2 +5,9 @@ # Changelog
 
+### [0.3.6](https://github.com/unjs/unev/compare/v0.3.5...v0.3.6) (2021-09-20)
+
+
+### Features
+
+* node stream duplex and transform ([#12](https://github.com/unjs/unev/issues/12)) ([940e72e](https://github.com/unjs/unev/commit/940e72efc2a6468af213f09909cc9c98685ddac8))
+
 ### [0.3.5](https://github.com/unjs/unev/compare/v0.3.4...v0.3.5) (2021-09-10)
@@ -7,0 +14,0 @@

package.json

 {
   "name": "unenv",
-  "version": "0.3.5",
+  "version": "0.3.6",
   "description": "",
@@ -5,0 +5,0 @@ "repository": "unjs/unev",

runtime/node/fs/index.js

@@ -8,4 +8,6 @@ "use strict";
 
-function _callSync(method, ...args) {}
+var _unstorage = require("unstorage");
 
+const storage = (0, _unstorage.createStorage)();
+
 const access = function (path, mode, callback) {
@@ -12,0 +14,0 @@ callback(null);

runtime/node/net/socket.d.ts

 /// <reference types="node" />
 import type * as net from 'net';
 import { Callback, BufferEncoding } from '../../_internal/types';
-import { Readable } from '../stream/readable';
-import { Writable } from '../stream/writable';
-declare type ReadableAndWritableT = Readable & Writable;
-declare type ReadableAndWritableC = new () => ReadableAndWritableT;
-declare const ReadableAndWritable: ReadableAndWritableC;
-export declare class Socket extends ReadableAndWritable implements net.Socket {
+import { Duplex } from '../stream/duplex';
+export declare class Socket extends Duplex implements net.Socket {
     readonly bufferSize: number;
@@ -34,2 +30,1 @@ readonly bytesRead: number;
 }
-export {};

runtime/node/net/socket.js

@@ -8,20 +8,5 @@ "use strict";
 
-var _readable = require("../stream/readable");
+var _duplex = require("../stream/duplex");
 
-var _writable = require("../stream/writable");
-
-var _utils = require("../../_internal/utils");
-
-const ReadableAndWritable = class {
-  constructor(readable = new _readable.Readable(), writable = new _writable.Writable()) {
-    Object.assign(this, readable);
-    Object.assign(this, writable);
-    this._destroy = (0, _utils.mergeFns)(readable._destroy, writable._destroy);
-  }
-
-};
-Object.assign(ReadableAndWritable.prototype, _readable.Readable.prototype);
-Object.assign(ReadableAndWritable.prototype, _writable.Writable.prototype);
-
-class Socket extends ReadableAndWritable {
+class Socket extends _duplex.Duplex {
   constructor(_options) {
@@ -28,0 +13,0 @@ super();

runtime/node/stream/index.d.ts

@@ -0,6 +1,12 @@
+/// <reference types="node" />
 import * as readable from './readable';
 import * as writable from './writable';
+import * as transform from './transform';
 export * from './readable';
 export * from './writable';
+export * from './duplex';
+export * from './transform';
 declare const _default: {
+    Transform: typeof transform.Transform;
+    Duplex: new () => import("stream").Duplex;
     Writable: typeof writable.Writable;
@@ -7,0 +13,0 @@ Readable: typeof readable.Readable;

runtime/node/stream/index.js

@@ -37,2 +37,30 @@ "use strict";
 
+var duplex = _interopRequireWildcard(require("./duplex"));
+
+Object.keys(duplex).forEach(function (key) {
+  if (key === "default" || key === "__esModule") return;
+  if (Object.prototype.hasOwnProperty.call(_exportNames, key)) return;
+  if (key in exports && exports[key] === duplex[key]) return;
+  Object.defineProperty(exports, key, {
+    enumerable: true,
+    get: function () {
+      return duplex[key];
+    }
+  });
+});
+
+var transform = _interopRequireWildcard(require("./transform"));
+
+Object.keys(transform).forEach(function (key) {
+  if (key === "default" || key === "__esModule") return;
+  if (Object.prototype.hasOwnProperty.call(_exportNames, key)) return;
+  if (key in exports && exports[key] === transform[key]) return;
+  Object.defineProperty(exports, key, {
+    enumerable: true,
+    get: function () {
+      return transform[key];
+    }
+  });
+});
+
 function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); }
@@ -43,4 +71,6 @@
 var _default = { ...readable,
-  ...writable
+  ...writable,
+  ...duplex,
+  ...transform
 };
 module.exports = _default;

No alert changes

Improved metrics

Total package byte prevSize

96699

2.39%

Number of package files

91

7.06%

Lines of code

2816

2.47%

No dependency changes