react-streaming - npm Package Compare versions

Comparing version 0.3.33-commit-2cf1712 to 0.3.33-commit-cf9cdf3

dist/cjs/server/renderToStream/createBuffer.js

@@ -9,2 +9,3 @@ "use strict";
     let state = 'UNSTARTED';
+    let writePermission = null; // Set to `null` because React fails to hydrate if something is injected before the first react write
     return { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded };
@@ -22,2 +23,5 @@ function injectToStream(chunk, options) {
     function flushBuffer() {
+        if (!writePermission) {
+            return;
+        }
         if (buffer.length === 0) {
@@ -49,8 +53,22 @@ return;
         if (debug.isEnabled) {
-            debug(`react write`, getChunkAsString(chunk));
+            debug(`react write${!writePermission ? '' : ' (allowed)'}`, getChunkAsString(chunk));
         }
         state = 'STREAMING';
-        flushBuffer();
+        if (writePermission) {
+            flushBuffer();
+        }
+        if (writePermission === null) {
+            writePermission = false;
+            debug('writePermission =', writePermission);
+            setTimeout(() => {
+                debug('>>> setTimeout()');
+                writePermission = true;
+                debug('writePermission =', writePermission);
+                flushBuffer();
+            }, 0);
+        }
     }
     function onBeforeEnd() {
+        writePermission = true;
+        debug('writePermission =', writePermission);
         flushBuffer();
@@ -57,0 +75,0 @@ (0, utils_1.assert)(buffer.length === 0);

dist/cjs/utils/projectInfo.js

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

dist/esm/server/renderToStream/createBuffer.js

@@ -7,2 +7,3 @@ export { createBuffer };
     let state = 'UNSTARTED';
+    let writePermission = null; // Set to `null` because React fails to hydrate if something is injected before the first react write
     return { injectToStream, onBeforeWrite, onBeforeEnd, hasStreamEnded };
@@ -20,2 +21,5 @@ function injectToStream(chunk, options) {
     function flushBuffer() {
+        if (!writePermission) {
+            return;
+        }
         if (buffer.length === 0) {
@@ -47,8 +51,22 @@ return;
         if (debug.isEnabled) {
-            debug(`react write`, getChunkAsString(chunk));
+            debug(`react write${!writePermission ? '' : ' (allowed)'}`, getChunkAsString(chunk));
         }
         state = 'STREAMING';
-        flushBuffer();
+        if (writePermission) {
+            flushBuffer();
+        }
+        if (writePermission === null) {
+            writePermission = false;
+            debug('writePermission =', writePermission);
+            setTimeout(() => {
+                debug('>>> setTimeout()');
+                writePermission = true;
+                debug('writePermission =', writePermission);
+                flushBuffer();
+            }, 0);
+        }
     }
     function onBeforeEnd() {
+        writePermission = true;
+        debug('writePermission =', writePermission);
         flushBuffer();
@@ -55,0 +73,0 @@ assert(buffer.length === 0);

dist/esm/utils/projectInfo.js

 export { projectInfo };
 import { getGlobalObject } from './getGlobalObject';
-const PROJECT_VERSION = '0.3.33-commit-2cf1712';
+const PROJECT_VERSION = '0.3.33-commit-cf9cdf3';
 const projectInfo = {
@@ -5,0 +5,0 @@ projectName: 'react-streaming',

package.json

 {
   "name": "react-streaming",
   "description": "React 18 Streaming. Full-fledged & Easy.",
-  "version": "0.3.33-commit-2cf1712",
+  "version": "0.3.33-commit-cf9cdf3",
   "peerDependencies": {
@@ -6,0 +6,0 @@ "react": ">=18",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

144617

increased by1.03%

Lines of code

3069

increased by1.19%

No dependency changes