fix: fix the queue example

Author: aminya

examples/package.json

@@ -10,6 +10,10 @@
   "scripts": {
     "majordomo": "ts-node ./majordomo/index.ts",
     "queue": "ts-node ./queue/index.ts",
-    "threaded-worker": "ts-node ./threaded-worker/index.ts"
+    "threaded-worker": "ts-node ./threaded-worker/index.ts",
+    "pub-sub": "ts-node ./pub-sub/index.ts",
+    "push-pull": "ts-node ./push-pull/index.ts",
+    "req-rep": "ts-node ./req-rep/index.ts",
+    "v5-compat": "node ./v5-compat/index.js"
   }
 }

examples/queue/index.ts

@@ -1,18 +1,23 @@
 import {Dealer} from "zeromq"
 
-import {Queue} from "./queue.js"
+import {Queue} from "./queue"
 
 async function main() {
   const sender = new Dealer()
   await sender.bind("tcp://127.0.0.1:5555")
+  console.log("sender bound to port 5555")
 
   const queue = new Queue(sender)
-  await queue.send("hello")
-  await queue.send("world!")
-  await queue.send(null)
+
+  const sent = Promise.all([
+    queue.send("hello"),
+    queue.send("world!"),
+    queue.send(null),
+  ])
 
   const receiver = new Dealer()
   receiver.connect("tcp://127.0.0.1:5555")
+  console.log("receiver connected to port 5555")
 
   for await (const [msg] of receiver) {
     if (msg.length === 0) {
@@ -22,6 +27,8 @@ async function main() {
       console.log(`received: ${msg}`)
     }
   }
+
+  await sent
 }
 
 main().catch(err => {

examples/queue/queue.ts

@@ -12,6 +12,7 @@ export class Queue {
   }
 
   send(msg: MessageLike) {
+    console.log(`Sending message: ${msg}`)
     if (this.queue.length > this.max) {
       throw new Error("Queue is full")
     }