edge-runtime - npm Package Compare versions

Comparing version 1.1.0-beta.34 to 1.1.0-beta.35

dist/edge-runtime.js

@@ -52,3 +52,3 @@ "use strict";
 process.on('unhandledRejection', function invokeRejectionHandlers(reason, promise) {
-    unhandledRejectionHandlers === null || unhandledRejectionHandlers === void 0 ? void 0 : unhandledRejectionHandlers.forEach((handler) => handler(reason, promise));
+    unhandledRejectionHandlers === null || unhandledRejectionHandlers === void 0 ? void 0 : unhandledRejectionHandlers.forEach((handler) => handler({ reason, promise }));
 });
@@ -55,0 +55,0 @@ process.on('uncaughtException', function invokeErrorHandlers(error) {

dist/index.d.ts

@@ -1,2 +0,2 @@
-export { createHandler, runServer } from './server';
+export { consumeUint8ArrayReadableStream, createHandler, runServer, } from './server';
 export { EdgeRuntime } from './edge-runtime';

dist/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.EdgeRuntime = exports.runServer = exports.createHandler = void 0;
+exports.EdgeRuntime = exports.runServer = exports.createHandler = exports.consumeUint8ArrayReadableStream = void 0;
 var server_1 = require("./server");
+Object.defineProperty(exports, "consumeUint8ArrayReadableStream", { enumerable: true, get: function () { return server_1.consumeUint8ArrayReadableStream; } });
 Object.defineProperty(exports, "createHandler", { enumerable: true, get: function () { return server_1.createHandler; } });
@@ -6,0 +7,0 @@ Object.defineProperty(exports, "runServer", { enumerable: true, get: function () { return server_1.runServer; } });

dist/server/body-streams.d.ts

@@ -21,2 +21,8 @@ /// <reference types="node" />
 };
+/**
+ * Creates an async iterator from a ReadableStream that ensures that every
+ * emitted chunk is a `Uint8Array`. If there is some invalid chunk it will
+ * throw.
+ */
+export declare function consumeUint8ArrayReadableStream(body?: ReadableStream): AsyncGenerator<Uint8Array, void, unknown>;
 export {};

dist/server/body-streams.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getClonableBodyStream = void 0;
+exports.consumeUint8ArrayReadableStream = exports.getClonableBodyStream = void 0;
 const stream_1 = require("stream");
@@ -70,2 +70,24 @@ /**
 }
+/**
+ * Creates an async iterator from a ReadableStream that ensures that every
+ * emitted chunk is a `Uint8Array`. If there is some invalid chunk it will
+ * throw.
+ */
+async function* consumeUint8ArrayReadableStream(body) {
+    var _a;
+    const reader = body === null || body === void 0 ? void 0 : body.getReader();
+    if (reader) {
+        while (true) {
+            const { done, value } = await reader.read();
+            if (done) {
+                return;
+            }
+            if (((_a = value === null || value === void 0 ? void 0 : value.constructor) === null || _a === void 0 ? void 0 : _a.name) !== 'Uint8Array') {
+                throw new TypeError('This ReadableStream did not return bytes.');
+            }
+            yield value;
+        }
+    }
+}
+exports.consumeUint8ArrayReadableStream = consumeUint8ArrayReadableStream;
 //# sourceMappingURL=body-streams.js.map

dist/server/create-handler.js

@@ -8,2 +8,3 @@ "use strict";
 const body_streams_1 = require("./body-streams");
+const body_streams_2 = require("./body-streams");
 const pretty_ms_1 = __importDefault(require("pretty-ms"));
@@ -25,3 +26,3 @@ const http_status_1 = __importDefault(require("http-status"));
             const body = req.method !== 'GET' && req.method !== 'HEAD'
-                ? (0, body_streams_1.getClonableBodyStream)(req, options.runtime.evaluate('Uint8Array'), options.runtime.context.TransformStream)
+                ? (0, body_streams_2.getClonableBodyStream)(req, options.runtime.evaluate('Uint8Array'), options.runtime.context.TransformStream)
                 : undefined;
@@ -44,3 +45,3 @@ const response = await options.runtime.dispatchFetch(String(getURL(req)), {
             if (response.body) {
-                for await (const chunk of response.body) {
+                for await (const chunk of (0, body_streams_1.consumeUint8ArrayReadableStream)(response.body)) {
                     res.write(chunk);
@@ -47,0 +48,0 @@ }

dist/server/index.d.ts

@@ -0,2 +1,3 @@
+export { consumeUint8ArrayReadableStream } from './body-streams';
 export { createHandler } from './create-handler';
 export { runServer } from './run-server';

dist/server/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.runServer = exports.createHandler = void 0;
+exports.runServer = exports.createHandler = exports.consumeUint8ArrayReadableStream = void 0;
+var body_streams_1 = require("./body-streams");
+Object.defineProperty(exports, "consumeUint8ArrayReadableStream", { enumerable: true, get: function () { return body_streams_1.consumeUint8ArrayReadableStream; } });
 var create_handler_1 = require("./create-handler");
@@ -5,0 +7,0 @@ Object.defineProperty(exports, "createHandler", { enumerable: true, get: function () { return create_handler_1.createHandler; } });

package.json

@@ -5,3 +5,3 @@ {
   "homepage": "https://edge-runtime.vercel.app/packages/runtime",
-  "version": "1.1.0-beta.34",
+  "version": "1.1.0-beta.35",
   "main": "dist/index.js",
@@ -8,0 +8,0 @@ "bin": {

No alert changes

Improved metrics

Total package byte prevSize

86783

increased by3.91%

Lines of code

765

increased by4.51%

No dependency changes