streams.js

'use strict';

const http = require('http');
const fs = require('fs');
const stream = require('stream');

const req = http.request({hostname:'localhost',port:5000,method:'PUT',path:'/'});

class Null extends stream.Writable {
	_write(chunk, encoding, callback) {
		callback();
	}
}

class ReqStream extends stream.Writable {
	constructor(req) {
		super();
		this.req = req;
		req.on('response', (res) => {
			res.pipe(new Null());
			if (res.statusCode !== 200) {
				this.emit('error', new Error(res.statusText));
				this.end();
			}
		});
	}

	_write(chunk, encoding, callback) {
		this.req.write(chunk, encoding, callback);
	}

	end(chunk, encoding, callback) {
		super.end(chunk, encoding, callback);
		this.req.end(chunk, encoding, callback);
	}
}

const target = new ReqStream(req);
//const input = fs.createReadStream('./streams.js');
const input = fs.createReadStream('/home/saml/Downloads/ReactOS-0.4.3.iso');
input.pipe(target);
new Promise((resolve, reject) => {
	target.on('finish', resolve);
	target.on('error', reject);
})
.then(() => console.log('bye'))
.catch((err) => console.log('err', err));