fix: allow running pub-sub, push-pull, req-rep examples

Author: aminya

examples/pub-sub/index.ts

@@ -0,0 +1,10 @@
+if (process.env.CI) {
+  // exit after 1 second in CI environment
+  setTimeout(() => {
+    process.exit(0)
+  }, 1000)
+}
+
+/* eslint-disable import/no-unassigned-import */
+import "./publisher"
+import "./subscriber"

examples/pub-sub/publisher.ts

@@ -6,6 +6,7 @@ async function run() {
   await sock.bind("tcp://127.0.0.1:3000")
   console.log("Publisher bound to port 3000")
 
+  // eslint-disable-next-line no-constant-condition, @typescript-eslint/no-unnecessary-condition
   while (true) {
     console.log("sending a multipart message envelope")
     await sock.send(["kitty cats", "meow!"])
@@ -15,4 +16,4 @@ async function run() {
   }
 }
 
-run()
+run().catch(console.error)

examples/pub-sub/subscriber.ts

@@ -17,4 +17,4 @@ async function run() {
   }
 }
 
-run()
+run().catch(console.error)

examples/push-pull/index.ts

@@ -0,0 +1,10 @@
+if (process.env.CI) {
+  // exit after 1 second in CI environment
+  setTimeout(() => {
+    process.exit(0)
+  }, 1000)
+}
+
+/* eslint-disable import/no-unassigned-import */
+import "./producer"
+import "./worker"

examples/push-pull/producer.ts

@@ -6,6 +6,7 @@ async function run() {
   await sock.bind("tcp://127.0.0.1:3000")
   console.log("Producer bound to port 3000")
 
+  // eslint-disable-next-line no-constant-condition, @typescript-eslint/no-unnecessary-condition
   while (true) {
     await sock.send("some work")
     await new Promise(resolve => {
@@ -14,4 +15,4 @@ async function run() {
   }
 }
 
-run()
+run().catch(console.error)

examples/push-pull/worker.ts

@@ -11,4 +11,4 @@ async function run() {
   }
 }
 
-run()
+run().catch(console.error)

examples/req-rep/client.ts

@@ -6,10 +6,11 @@ async function run() {
   sock.connect("tcp://127.0.0.1:3000")
   console.log("Producer bound to port 3000")
 
-  await sock.send("4")
-  const [result] = await sock.receive()
+  await sock.send(4)
+  console.log("Request a calculation for 4")
 
-  console.log(result)
+  const [result] = await sock.receive()
+  console.log(`Received result: ${result}`)
 }
 
-run()
+run().catch(console.error)

examples/req-rep/index.ts

@@ -0,0 +1,10 @@
+if (process.env.CI) {
+  // exit after 1 second in CI environment
+  setTimeout(() => {
+    process.exit(0)
+  }, 1000)
+}
+
+/* eslint-disable import/no-unassigned-import */
+import "./client"
+import "./server"

examples/req-rep/server.ts

@@ -6,8 +6,13 @@ async function run() {
   await sock.bind("tcp://127.0.0.1:3000")
 
   for await (const [msg] of sock) {
-    await sock.send((2 * parseInt(msg.toString(), 10)).toString())
+    // parse the message as a number
+    const value = parseInt(msg.toString(), 10)
+
+    // calculate the result and send it back to the client
+    const result = 2 * value
+    await sock.send(result)
   }
 }
 
-run()
+run().catch(console.error)