busrt 0.5.5

Local and network IPC bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

"use strict";

import ntqdm from "ntqdm";
import sleep from "sleep-promise";

import { Bus, Frame, QoS } from "busrt";

const onDisconnect = async () => {
  console.log("BUS/RT disconnected");
};

const onFrame = async (frame) => {
  //console.log(frame, frame.getPayload().toString());
};

function* generator(steps) {
  let index = 0;
  while (true) {
    yield index;
    index += 1;
  }
}

const test = async () => {
  const bus = new Bus("js");
  bus.onDisconnect = onDisconnect;
  bus.onFrame = onFrame;
  //await bus.connect(("localhost", 9924));
  await bus.connect("/tmp/busrt.sock");
  const op = await bus.subscribe(["#"]);
  console.log(await op.waitCompleted());
  const op2 = await bus.unsubscribe(["#"]);
  console.log(await op.waitCompleted());
  //op = await bus.unsubscribe(["#"]);
  //console.log(await op.waitCompleted());
  //while (bus.isConnected()) {
  //console.log(bus.isConnected());
  //await sleep(1000);
  //}
  //return;
  let iters = 200_000;
  const payload = "hello";
  let start = new Date().getTime() / 1000;
  var tdqm = ntqdm();
  for (let i of ntqdm(generator(iters), { total: iters, logging: true })) {
    const op = await bus.publish("test", payload, QoS.Processed);
    await op.waitCompleted();
  }
  const elapsed = new Date().getTime() / 1000 - start;
  const speed = Math.round(iters / elapsed);
  console.log(speed, "iters/s");
  console.log(Math.round(1_000_000 / speed), "us per iter");
  await bus.disconnect();
};

test();