How can we use NATS streaming from node/hemera services?

[kristianmandrup]

We have a hemera service which generates a stream as output and looking to exploit the NATS streaming server. Any examples or docs for this?

Thanks :)

https://github.com/devongovett/node-wkhtmltopdf#usage

// Stream input and output
var stream = wkhtmltopdf(fs.createReadStream('file.html'));

// Optional callback
wkhtmltopdf('http://google.com/', { pageSize: 'letter' }, function (err, stream) {
  // do whatever with the stream
});

Somehow use this stream it with NATS streaming and hemera...

exports.generatePdf = function (opts) {
  hemera.act(pattern.publish, function (err, resp) {
    resp.send({
      opts
    })
  })
}

exports.listenAndStream = function (res) {
  // Subscribe to result from html2pdf generator service
  hemera.add(pattern.subscribe, function (req, cb) {
    console.log('request:', req.stream);
    res.stream(req.stream);
    res.close();
  })
}

[kozlovic]

We have a node streaming client, did you have a look? https://github.com/nats-io/node-nats-streaming

[kristianmandrup]

Great! Didn't notice any reference, but maybe since it is WIP. How long till it is out of incubation? Can it be used now for basic usage? Cheers :)

[kozlovic]

I will let the owner of the repo that he should probably remove the WIP ;-) There are already releases and people have been using it. Of course, any issue that you find, please file a GH issue. Thanks!

[kristianmandrup]

Awesome thanks :)