Possibly fixes jarrodek/ChromeRestClient#640

Author: jarrodek

app.fetch.js

@@ -1089,6 +1089,12 @@ class SocketFetch extends ArcEventSource {
         if (!this._connection.chunkSize) {
           data = this.readChunkSize(data);
           this.log('Chunk size: ', this._connection.chunkSize);
+          if (this._connection.chunkSize === null) {
+            // It may happen that chrome's buffer cuts the data
+            // just before the chunk size.
+            // It should proceed it in next portion of the data.
+            return;
+          }
           if (!this._connection.chunkSize) {
             this.onResponseReady();
             return;
@@ -1290,6 +1296,10 @@ class SocketFetch extends ArcEventSource {
     }
     var sizeArray = array.subarray(0, index);
     var sizeHex = this.arrayBufferToString(sizeArray);
+    if (!sizeHex || sizeHex === '') {
+      this._connection.chunkSize = null;
+      return array.subarray(index + 2);
+    }
     this._connection.chunkSize = parseInt(sizeHex, 16);
     return array.subarray(index + 2);
   }

bower.json

@@ -1,6 +1,6 @@
 {
   "name": "socket-fetch",
-  "version": "1.0.41",
+  "version": "1.0.42",
   "license": "LICENSE.txt",
   "description": "A HTTP transport based on chrome.socket.tcp API.",
   "authors": [

demo/index.html

@@ -133,9 +133,10 @@ <h2>Log</h2>
 
   demo.addEventListener('dom-change', function() {
     // demo.set('url', 'https://chromerestclient.appspot.com/test?p=json');
-    demo.set('url', 'http://localhost:8081/redirect');
+    // demo.set('url', 'http://localhost:8081/redirect');
+    demo.url = 'https://httpbin.org/range/75776?chunk_size=150';
     demo.set('payload', '{"test":"request"}');
-    demo.set('method', 'POST');
+    demo.set('method', 'GET');
     demo.set('headers',
     `Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8
 Accept-Encoding: gzip, deflate
@@ -165,7 +166,7 @@ <h2>Log</h2>
             demo.push('logs', {
               log: 'Received response.'
             });
-            console.log('Fetch result', result);
+            // console.log('Fetch result', result);
           })
           .catch((cause) => {
             demo.push('logs', {
@@ -179,7 +180,7 @@ <h2>Log</h2>
           demo.push('logs', {
             log: log
           });
-          console.log('Fetch result', response);
+          // console.log('Fetch result', response);
         }
       })
       .catch((cause) => {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "socket-fetch",
-  "version": "1.0.41",
+  "version": "1.0.42",
   "license": "LICENSE",
   "description": "A HTTP transport based on chrome.socket.tcp API.",
   "scripts": {