EDDN/examples/NodeJS/index.js
2021-04-10 00:23:40 +03:00

20 lines
393 B
JavaScript

const zlib = require('zlib')
const zmq = require('zeromq')
const SOURCE_URL = 'tcp://eddn.edcd.io:9500'
async function run () {
const sock = new zmq.Subscriber
sock.connect(SOURCE_URL)
sock.subscribe('')
console.log('EDDN listener connected to:', SOURCE_URL)
for await (const [ src ] of sock) {
const msg = JSON.parse(zlib.inflateSync(src))
console.log(msg)
}
}
run()