fix blocking in ai first

d21d71cd · Chunchi Che · ec1837e9 · d21d71cd · d21d71cd · d21d71cd
Commit d21d71cd authored Jun 05, 2023 by Chunchi Che
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 5 deletions

neos.config.json neos.config.json +1 -1

neos.config.prod.json neos.config.prod.json +1 -1

src/infra/stream.ts src/infra/stream.ts +3 -3

No files found.
--- a/neos.config.json
+++ b/neos.config.json
@@ -11,7 +11,7 @@
   "cardsDbUrl":"https://cdn02.moecube.com:444/ygopro-database/zh-CN/cards.cdb",
   "stringsUrl":"https://cdn02.moecube.com:444/ygopro-database/zh-CN/strings.conf",
   "chainALL": false,
-   "streamInterval": 200,
+   "streamInterval": 20,
   "ui":{
      "hint":{
         "waitingDuration":1.5,

--- a/neos.config.prod.json
+++ b/neos.config.prod.json
@@ -11,7 +11,7 @@
   "cardsDbUrl":"https://cdn02.moecube.com:444/ygopro-database/zh-CN/cards.cdb",
   "stringsUrl":"https://cdn02.moecube.com:444/ygopro-database/zh-CN/strings.conf",
   "chainALL": false,
-   "streamInterval": 200,
+   "streamInterval": 20,
   "ui":{
      "hint":{
         "waitingDuration":1.5,

--- a/src/infra/stream.ts
+++ b/src/infra/stream.ts
@@ -53,14 +53,14 @@ export class WebSocketStream {

          return;
        } else {
-          // websocket not closed, wait some time, and then handle next message from server
-
-          await sleep(useConfig().streamInterval);
+          // websocket not closed, handle next message from server
          await reader.read().then(process);
        }
      }

      if (value) {
+        // wait some time, and then handle message from server
+        await sleep(useConfig().streamInterval);
        await onMessage(value);
      } else {
        console.warn("value from ReadableStream is undefined!");