async-writer-basic.js

require('marko/node-require').install();
const http = require('http');
const server = require('http').createServer();
const port = 8080;

server.on('request', (req, res) => {
  var out = require('async-writer').create(res)
  .on('error', function(err) {
      // Something went wrong during writing
  })
  .on('end', function() {
      // Value of output: "ABC"
  });

  out.write('A');
  out.write('B');
  out.write('C');
  out.end();
});
server.listen(port, () => {
  console.log(`Successfully started server on port ${port}`);
});