elbus 0.2.21

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
57
58

// TODO set buffer size
// TODO timeouts
// TODO package, docs and examples

"use strict";

const ntqdm = require("ntqdm");
const sleep = require("sleep-promise");

const elbus = require("./elbus/src/elbus.js");

async function disconnected() {
  console.log("elbus disconnected");
}

async function on_frame(frame) {
  console.log(frame, frame.get_payload().toString());
}
function* generator(steps) {
  let index = 0;
  while (true) {
    yield index;
    index += 1;
  }
}

async function test() {
  let bus = new elbus.Client("js");
  bus.on_disconnect = disconnected;
  bus.on_frame = on_frame;
  //await bus.connect(("localhost", 9924));
  await bus.connect("/tmp/elbus.sock");
  let op = await bus.subscribe(["tests", "xxz"]);
  console.log(await op.wait_completed());
  op = await bus.unsubscribe(["tests", "xxz"]);
  console.log(await op.wait_completed());
  //while (bus.is_connected()) {
  //console.log(bus.is_connected());
  //await sleep(1000);
  //}
  //return;
  let iters = 200_000;
  let msg = new elbus.Frame(elbus.OP_MESSAGE, 0);
  msg.payload = Buffer.from("hello");
  let start = new Date().getTime() / 1000;
  var tdqm = ntqdm();
  for (let i of ntqdm(generator(iters), { total: iters, logging: true })) {
    let op = await bus.send("y", msg);
    await op.wait_completed();
  }
  let elapsed = new Date().getTime() / 1000 - start;
  let 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();