How to use the zeromq.Subscriber function in zeromq
To help you get started, we’ve selected a few zeromq examples, based on popular ways it is used in public projects.
Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
alibaba / pipcook / packages / pipcook-python-node / src / communication / communication.ts View on Github 
});
return false;
});
const session: Session = {
id,
parent_header: {},
last_header: {
msg_id: "init_id",
msg_type: "execute_request",
username: 'pipcook',
version: "5.0",
session: "pipcook_session"
},
dealerMsg: {},
socketDealer: new zmq.Dealer,
socketSubscriber: new zmq.Subscriber,
timer: null,
ioPort: Executor.latestIoPort,
shellPort: Executor.latestShellPort,
kernel
}
Executor.latestIoPort++;
Executor.latestShellPort++;
Executor.sessions.push(session);
return session;
}zeromq
Next-generation ZeroMQ bindings for Node.js
