grpc-request.js

grpc-request.js

var pumpify = require('pumpify')
var through = require('through2')

function makeGrpcStreamingRequest() {
  var transformStream = through.obj(function(obj, enc, next) {
    obj.transformed = true
    next(null, obj)
  })

  var grpcRequestStream = through.obj()

  return pumpify.obj(transformStream, grpcRequestStream)
}

var stream = makeGrpcStreamingRequest()
stream.on('data', console.log)

var request = {
  configurationSetting: true,
  anotherSetting: false
}
stream.write(request)

var anotherRequest = {
  configurationSetting: false,
  anotherSetting: true
}
stream.write(anotherRequest)

stream.end()

// Actual requests sent (output from `console.log`):
// {
//   configurationSetting: true,
//   anotherSetting: false,
//   transformed: true
// }
//
// {
//   configurationSetting: false,
//   anotherSetting: true,
//   transformed: true
// }