feat: Port rest of panrpc examples to context/signal-aware API in Typ…

…eScript version Signed-off-by: Felicitas Pojtinger <felicitas@pojtinger.com>
pojntfx · Aug 15, 2024 · 526cb38 · 526cb38
1 parent 767017b
commit 526cb38
Show file tree

Hide file tree

Showing 6 changed files with 35 additions and 0 deletions.
diff --git a/ts/bin/panrpc-example-websocket-client-cli.ts b/ts/bin/panrpc-example-websocket-client-cli.ts
@@ -110,6 +110,8 @@ if (listen) {
       console.error("Client disconnected with error:", e);
     });
 
+    const linkSignal = new AbortController();
+
     const encoder = new WritableStream({
       write(chunk) {
         socket.send(JSON.stringify(chunk));
@@ -149,9 +151,12 @@ if (listen) {
     socket.addEventListener("close", () => {
       parserReader.cancel();
       parserWriter.abort();
+      linkSignal.abort();
     });
 
     registry.linkStream(
+      linkSignal.signal,
+
       encoder,
       decoder,
 
@@ -176,6 +181,8 @@ if (listen) {
     socket.addEventListener("error", rej);
   });
 
+  const linkSignal = new AbortController();
+
   const encoder = new WritableStream({
     write(chunk) {
       socket.send(JSON.stringify(chunk));
@@ -215,9 +222,12 @@ if (listen) {
   socket.addEventListener("close", () => {
     parserReader.cancel();
     parserWriter.abort();
+    linkSignal.abort();
   });
 
   registry.linkStream(
+    linkSignal.signal,
+
     encoder,
     decoder,
 

diff --git a/ts/bin/panrpc-example-websocket-client-web/app/page.tsx b/ts/bin/panrpc-example-websocket-client-web/app/page.tsx
@@ -52,6 +52,8 @@ export default function Home() {
       socket.addEventListener("error", rej);
     });
 
+    const linkSignal = new AbortController();
+
     const encoder = new WritableStream({
       write(chunk) {
         socket.send(JSON.stringify(chunk));
@@ -91,9 +93,12 @@ export default function Home() {
     socket.addEventListener("close", () => {
       parserReader.cancel();
       parserWriter.abort();
+      linkSignal.abort();
     });
 
     registry.linkStream(
+      linkSignal.signal,
+
       encoder,
       decoder,
 

diff --git a/ts/bin/panrpc-example-websocket-client-web/bun.lockb b/ts/bin/panrpc-example-websocket-client-web/bun.lockb
diff --git a/ts/bin/panrpc-example-websocket-coffee-client-cli.ts b/ts/bin/panrpc-example-websocket-coffee-client-cli.ts
@@ -134,6 +134,8 @@ await new Promise<void>((res, rej) => {
   socket.addEventListener("error", rej);
 });
 
+const linkSignal = new AbortController();
+
 // Set up streaming JSON encoder
 const encoder = new WritableStream({
   write(chunk) {
@@ -173,9 +175,12 @@ socket.addEventListener("message", (m) => parserWriter.write(m.data as string));
 socket.addEventListener("close", () => {
   parserReader.cancel();
   parserWriter.abort();
+  linkSignal.abort();
 });
 
 registry.linkStream(
+  linkSignal.signal,
+
   encoder,
   decoder,
 

diff --git a/ts/bin/panrpc-example-websocket-coffee-server-cli.ts b/ts/bin/panrpc-example-websocket-coffee-server-cli.ts
@@ -124,6 +124,8 @@ server.on("connection", (socket) => {
     console.error("Remote control disconnected with error:", e);
   });
 
+  const linkSignal = new AbortController();
+
   // Set up streaming JSON encoder
   const encoder = new WritableStream({
     write(chunk) {
@@ -165,9 +167,12 @@ server.on("connection", (socket) => {
   socket.addEventListener("close", () => {
     parserReader.cancel();
     parserWriter.abort();
+    linkSignal.abort();
   });
 
   registry.linkStream(
+    linkSignal.signal,
+
     encoder,
     decoder,
 

diff --git a/ts/bin/panrpc-example-websocket-server-cli.ts b/ts/bin/panrpc-example-websocket-server-cli.ts
@@ -106,6 +106,8 @@ if (listen) {
       console.error("Client disconnected with error:", e);
     });
 
+    const linkSignal = new AbortController();
+
     const encoder = new WritableStream({
       write(chunk) {
         socket.send(JSON.stringify(chunk));
@@ -145,9 +147,12 @@ if (listen) {
     socket.addEventListener("close", () => {
       parserReader.cancel();
       parserWriter.abort();
+      linkSignal.abort();
     });
 
     registry.linkStream(
+      linkSignal.signal,
+
       encoder,
       decoder,
 
@@ -172,6 +177,8 @@ if (listen) {
     socket.addEventListener("error", rej);
   });
 
+  const linkSignal = new AbortController();
+
   const encoder = new WritableStream({
     write(chunk) {
       socket.send(JSON.stringify(chunk));
@@ -211,9 +218,12 @@ if (listen) {
   socket.addEventListener("close", () => {
     parserReader.cancel();
     parserWriter.abort();
+    linkSignal.abort();
   });
 
   registry.linkStream(
+    linkSignal.signal,
+
     encoder,
     decoder,