pageSize

Author: odeimaiz

services/static-webserver/client/source/class/osparc/data/StreamTask.js

@@ -38,18 +38,33 @@ qx.Class.define("osparc.data.StreamTask", {
     streamHref: {
       check: "String",
       nullable: false,
+      init: null,
+    },
+
+    end: {
+      check: "Boolean",
+      nullable: false,
+      init: false,
+    },
+
+    pageSize: {
+      check: "Number",
+      nullable: false,
+      // init: 20,
+      init: 2,
     },
   },
 
   members: {
     _startPolling: function() {
-      this.__fetchStream();
+      this.fetchStream();
     },
 
-    __fetchStream: function() {
+    fetchStream: function() {
       if (!this.isDone()) {
         const streamPath = osparc.data.PollTask.extractPathname(this.getStreamHref());
-        fetch(streamPath)
+        const url = `${streamPath}?limit=${this.getPageSize()}`;
+        fetch(url)
           .then(resp => {
             if (resp.status === 200) {
               return resp.json();
@@ -64,11 +79,16 @@ qx.Class.define("osparc.data.StreamTask", {
               throw streamData["error"];
             }
             if ("data" in streamData && streamData["data"]) {
-              const data = streamData["data"];
-              this.fireDataEvent("streamReceived", data);
-              if ("end" in data && data["end"] === false) {
-                setTimeout(() => this.__fetchStream(), this.getPollInterval());
-              } else {
+              const items = streamData["data"]["items"] || [];
+              const end = streamData["data"]["end"] || false;
+              if (items.length === 0 && end === false) {
+                // nothing to stream yet, try again later
+                setTimeout(() => this.fetchStream(), this.getPollInterval());
+                return;
+              }
+              this.fireDataEvent("streamReceived", items);
+              if (end) {
+                this.setEnd(true);
                 this.setDone(true);
               }
               return;