client.js

var fs        =  require("fs")
var request   = require("request")
var filePath  = __dirname + "/payload.tar.gz"

fs.createReadStream(filePath).pipe(request.put('http://api.lvh.me:3001/').pipe(process.stdout))

package.json

{
  "name": "uploadtest",
  "version": "0.0.0",
  "description": "test upload streams",
  "scripts": {
    "start": "node server.js"
  },
  "dependencies": {
    "request": ""
  }
}

server.js

var http = require("http")
var fs   = require('fs')
var port = process.env.PORT || 3001

http.createServer(function(req, rsp){

  rsp.writeHead(200, {
    'Content-Type': 'text/event-stream',
    'Cache-Control': 'no-cache',
    'Connection': 'keep-alive'
  })

  req.pipe(fs.createWriteStream(__dirname + "/heyo.tar.gz"))

  // req.on('data', function(chunk){
  //   rsp.write("got a chunk: " +  chunk + "\n")
  // })

  // req.on('end', function() {
  //   rsp.end("all done" + "\n")
  // })

  setInterval(function(){
    rsp.write("progress")
  }, 100)

  setTimeout(function(){
    rsp.end("done")
  }, 5000)

}).listen(port)