Publisher

pub.js

zmq = require('zeromq');

s = zmq.createSocket('pub');

count = 0;

function send() {
  
  for (var i = 0; i < 1000; i++) {
    s.send("data");
  }

}

s.bind("ipc://unbalanced", function() {
  console.log("bind");
  setInterval(send, 1);
});

sub.js

zmq = require('zeromq');

s = zmq.createSocket('sub');

count = 0;

s._subscribe = "";

s.on("message", function(data) {
  if (count == 0) {
    console.time("speedtest:");
  }
  if (count++ == 100000) {
    console.timeEnd("speedtest:");
    s.close();
  }
});
s.connect("ipc://unbalanced");