Streaming Node.js function

function.json

{
  "bindings": [
    {
      "type": "blobTrigger",
      "name": "input",
      "direction": "in",
      "dataType": "stream",
      "path": "test-input-node/{name}"
    },
    {
      "type": "blob",
      "name": "output",
      "direction": "out",
      "dataType": "stream",
      "path": "test-output-node/{name}"
    }
  ]
}

index.js

const zlib = require('zlib');

module.exports = function (context, input) {
  input
    .pipe(zlib.createGzip())
    .pipe(context.bindings.output)
    .on('finish', context.done);
};