react-streaming - npm Package Compare versions

Comparing version 0.3.31 to 0.3.32

dist/cjs/server/renderToStream.d.ts

@@ -33,2 +33,3 @@ export { renderToStream };
     streamEnd: Promise<boolean>;
+    hasStreamEnded: () => boolean;
     disabled: boolean;
@@ -35,0 +36,0 @@ injectToStream: InjectToStream;

dist/cjs/server/renderToStream/createBuffer.d.ts

@@ -6,3 +6,3 @@ export { createBuffer };
     flush?: boolean;
-    expectStreamEnd?: boolean;
+    tolerateStreamEnded?: boolean;
 };
@@ -20,2 +20,3 @@ declare type InjectToStream = (chunk: unknown, options?: InjectToStreamOptions) => boolean;
     onBeforeEnd: () => void;
+    hasStreamEnded: () => boolean;
 };

dist/cjs/server/renderToStream/createBuffer.js

@@ -10,3 +10,3 @@ "use strict";
     let writePermission = null; // Set to `null` because React fails to hydrate if something is injected before the first react write
-    return { injectToStream, onBeforeWrite, onBeforeEnd };
+    return { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded };
     function injectToStream(chunk, options) {
@@ -16,4 +16,4 @@ if (debug.isEnabled) {
         }
-        if (state === 'ENDED') {
-            if (!(options === null || options === void 0 ? void 0 : options.expectStreamEnd)) {
+        if (hasStreamEnded()) {
+            if (!(options === null || options === void 0 ? void 0 : options.tolerateStreamEnded)) {
                 (0, utils_1.assertUsage)(state, `Cannot inject following chunk after stream has ended:\n${getChunkAsString(chunk)}`);
@@ -82,2 +82,5 @@ }
     }
+    function hasStreamEnded() {
+        return state === 'ENDED';
+    }
 }
@@ -84,0 +87,0 @@ exports.createBuffer = createBuffer;

dist/cjs/server/renderToStream/createPipeWrapper.d.ts

@@ -13,2 +13,3 @@ /// <reference types="node" />
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 }>;

dist/cjs/server/renderToStream/createPipeWrapper.js

@@ -13,4 +13,4 @@ "use strict";
     };
-    const { injectToStream, onBeforeWrite, onBeforeEnd } = (0, createBuffer_1.createBuffer)(streamOperations);
-    return { pipeForUser, streamEnd, injectToStream };
+    const { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded } = (0, createBuffer_1.createBuffer)(streamOperations);
+    return { pipeForUser, streamEnd, injectToStream, hasStreamEnded };
     function createPipeForUser() {
@@ -17,0 +17,0 @@ debug('createPipeForUser()');

dist/cjs/server/renderToStream/createReadableWrapper.d.ts

@@ -8,2 +8,3 @@ export { createReadableWrapper };
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 };

dist/cjs/server/renderToStream/createReadableWrapper.js

@@ -23,4 +23,4 @@ "use strict";
     });
-    const { injectToStream, onBeforeWrite, onBeforeEnd } = (0, createBuffer_1.createBuffer)(streamOperations);
-    return { readableForUser, streamEnd, injectToStream };
+    const { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded } = (0, createBuffer_1.createBuffer)(streamOperations);
+    return { readableForUser, streamEnd, injectToStream, hasStreamEnded };
     async function onReady(onEnded) {
@@ -27,0 +27,0 @@ streamOperations.operations = {

dist/cjs/server/renderToStream/renderToNodeStream.d.ts

@@ -18,2 +18,3 @@ export { renderToNodeStream };
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 }>;

dist/cjs/server/renderToStream/renderToNodeStream.js

@@ -50,3 +50,3 @@ "use strict";
     let promiseResolved = false;
-    const { pipeForUser, injectToStream, streamEnd } = await (0, createPipeWrapper_1.createPipeWrapper)(pipeOriginal, {
+    const { pipeForUser, injectToStream, streamEnd, hasStreamEnded } = await (0, createPipeWrapper_1.createPipeWrapper)(pipeOriginal, {
         stopTimeout,
@@ -78,4 +78,5 @@ onReactBug(err) {
         injectToStream,
+        hasStreamEnded,
     };
 }
 exports.renderToNodeStream = renderToNodeStream;

dist/cjs/server/renderToStream/renderToWebStream.d.ts

@@ -21,2 +21,3 @@ export { renderToWebStream };
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 }>;

dist/cjs/server/renderToStream/renderToWebStream.js

@@ -52,3 +52,5 @@ "use strict";
         throw firstErr;
-    const { readableForUser, streamEnd, injectToStream } = (0, createReadableWrapper_1.createReadableWrapper)(readableOriginal, { stopTimeout });
+    const { readableForUser, streamEnd, injectToStream, hasStreamEnded } = (0, createReadableWrapper_1.createReadableWrapper)(readableOriginal, {
+        stopTimeout,
+    });
     promiseResolved = true;
@@ -61,4 +63,5 @@ return {
         injectToStream,
+        hasStreamEnded,
     };
 }
 exports.renderToWebStream = renderToWebStream;

dist/cjs/utils/projectInfo.js

@@ -5,3 +5,3 @@ "use strict";
 const getGlobalObject_1 = require("./getGlobalObject");
-const PROJECT_VERSION = '0.3.31';
+const PROJECT_VERSION = '0.3.32';
 const projectInfo = {
@@ -8,0 +8,0 @@ projectName: 'react-streaming',

dist/esm/server/renderToStream.d.ts

@@ -33,2 +33,3 @@ export { renderToStream };
     streamEnd: Promise<boolean>;
+    hasStreamEnded: () => boolean;
     disabled: boolean;
@@ -35,0 +36,0 @@ injectToStream: InjectToStream;

dist/esm/server/renderToStream/createBuffer.d.ts

@@ -6,3 +6,3 @@ export { createBuffer };
     flush?: boolean;
-    expectStreamEnd?: boolean;
+    tolerateStreamEnded?: boolean;
 };
@@ -20,2 +20,3 @@ declare type InjectToStream = (chunk: unknown, options?: InjectToStreamOptions) => boolean;
     onBeforeEnd: () => void;
+    hasStreamEnded: () => boolean;
 };

dist/esm/server/renderToStream/createBuffer.js

@@ -8,3 +8,3 @@ export { createBuffer };
     let writePermission = null; // Set to `null` because React fails to hydrate if something is injected before the first react write
-    return { injectToStream, onBeforeWrite, onBeforeEnd };
+    return { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded };
     function injectToStream(chunk, options) {
@@ -14,4 +14,4 @@ if (debug.isEnabled) {
         }
-        if (state === 'ENDED') {
-            if (!(options === null || options === void 0 ? void 0 : options.expectStreamEnd)) {
+        if (hasStreamEnded()) {
+            if (!(options === null || options === void 0 ? void 0 : options.tolerateStreamEnded)) {
                 assertUsage(state, `Cannot inject following chunk after stream has ended:\n${getChunkAsString(chunk)}`);
@@ -80,2 +80,5 @@ }
     }
+    function hasStreamEnded() {
+        return state === 'ENDED';
+    }
 }
@@ -82,0 +85,0 @@ function getChunkAsString(chunk) {

dist/esm/server/renderToStream/createPipeWrapper.d.ts

@@ -13,2 +13,3 @@ /// <reference types="node" />
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 }>;

dist/esm/server/renderToStream/createPipeWrapper.js

@@ -11,4 +11,4 @@ export { createPipeWrapper };
     };
-    const { injectToStream, onBeforeWrite, onBeforeEnd } = createBuffer(streamOperations);
-    return { pipeForUser, streamEnd, injectToStream };
+    const { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded } = createBuffer(streamOperations);
+    return { pipeForUser, streamEnd, injectToStream, hasStreamEnded };
     function createPipeForUser() {
@@ -15,0 +15,0 @@ debug('createPipeForUser()');

dist/esm/server/renderToStream/createReadableWrapper.d.ts

@@ -8,2 +8,3 @@ export { createReadableWrapper };
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 };

dist/esm/server/renderToStream/createReadableWrapper.js

@@ -21,4 +21,4 @@ export { createReadableWrapper };
     });
-    const { injectToStream, onBeforeWrite, onBeforeEnd } = createBuffer(streamOperations);
-    return { readableForUser, streamEnd, injectToStream };
+    const { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded } = createBuffer(streamOperations);
+    return { readableForUser, streamEnd, injectToStream, hasStreamEnded };
     async function onReady(onEnded) {
@@ -25,0 +25,0 @@ streamOperations.operations = {

dist/esm/server/renderToStream/renderToNodeStream.d.ts

@@ -18,2 +18,3 @@ export { renderToNodeStream };
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 }>;

dist/esm/server/renderToStream/renderToNodeStream.js

@@ -53,3 +53,3 @@ export { renderToNodeStream };
     let promiseResolved = false;
-    const { pipeForUser, injectToStream, streamEnd } = await createPipeWrapper(pipeOriginal, {
+    const { pipeForUser, injectToStream, streamEnd, hasStreamEnded } = await createPipeWrapper(pipeOriginal, {
         stopTimeout,
@@ -81,3 +81,4 @@ onReactBug(err) {
         injectToStream,
+        hasStreamEnded,
     };
 }

dist/esm/server/renderToStream/renderToWebStream.d.ts

@@ -21,2 +21,3 @@ export { renderToWebStream };
     injectToStream: import("./createBuffer").InjectToStream;
+    hasStreamEnded: () => boolean;
 }>;

dist/esm/server/renderToStream/renderToWebStream.js

@@ -54,3 +54,5 @@ export { renderToWebStream };
         throw firstErr;
-    const { readableForUser, streamEnd, injectToStream } = createReadableWrapper(readableOriginal, { stopTimeout });
+    const { readableForUser, streamEnd, injectToStream, hasStreamEnded } = createReadableWrapper(readableOriginal, {
+        stopTimeout,
+    });
     promiseResolved = true;
@@ -63,3 +65,4 @@ return {
         injectToStream,
+        hasStreamEnded,
     };
 }

dist/esm/utils/projectInfo.js

 export { projectInfo };
 import { getGlobalObject } from './getGlobalObject';
-const PROJECT_VERSION = '0.3.31';
+const PROJECT_VERSION = '0.3.32';
 const projectInfo = {
@@ -5,0 +5,0 @@ projectName: 'react-streaming',

package.json

 {
   "name": "react-streaming",
   "description": "React 18 Streaming. Full-fledged & Easy.",
-  "version": "0.3.31",
+  "version": "0.3.32",
   "peerDependencies": {
@@ -6,0 +6,0 @@ "react": ">=18",

No alert changes

Improved metrics

Total package byte prevSize

143994

increased by0.65%

Lines of code

3065

increased by0.86%

No dependency changes