fixe timeout value

golang-cz · Dec 8, 2023 · 2770f1b · 2770f1b
1 parent ea9b082
commit 2770f1b
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 13 deletions.
diff --git a/_examples/golang-sse/webapp/src/rpc.ts b/_examples/golang-sse/webapp/src/rpc.ts
@@ -193,7 +193,7 @@ const sseResponse = async (
   const reader = res.body.getReader();
   const decoder = new TextDecoder();
   let buffer = "";
-  const timeout = 10 + 1 * 1000;
+  const timeout = (10 + 1) * 1000;
 
   while (true) {
     let value;

diff --git a/_examples/golang-sse/webapp/tests/sse.test.ts b/_examples/golang-sse/webapp/tests/sse.test.ts
@@ -162,16 +162,24 @@ test("call onError with WebrpcStreamLostError on stream error", async () => {
   expect(error).toEqual(new WebrpcStreamLostError());
 });
 
-test("call onError with WebrpcStreamLostError on stream timeout", async () => {
-  const mockFetch = createMockFetch({ closeStream: false });
-  const api = new Chat("", mockFetch);
-  let error: WebrpcError | undefined;
-
-  const onError = (err: WebrpcError) => {
-    error = err;
-  };
-
-  await api.subscribeMessages({ serverTimeoutSec: 10 }, { onMessage, onError });
+test(
+  "call onError with WebrpcStreamLostError on stream timeout",
+  async () => {
+    const mockFetch = createMockFetch({ closeStream: false });
+    const api = new Chat("", mockFetch);
+    let error: WebrpcError | undefined;
+
+    const onError = (err: WebrpcError) => {
+      console.log("onError()", err);
+      error = err;
+    };
+
+    await api.subscribeMessages(
+      { serverTimeoutSec: 10 },
+      { onMessage, onError }
+    );
 
-  expect(error).toEqual(new WebrpcStreamLostError());
-});
+    expect(error).toEqual(new WebrpcStreamLostError());
+  },
+  20 * 1000
+);