Vectormike

const stream = require('stream')

const readStream = new stream.Readable({
	read() {}
})

const writeStream = new stream.Writable()

writeStream._write = (chunk, encoding, next) => {
  next()

Vectormike

const stream = require('stream');

console.log(stream);

Vectormike

const { PassThrough } = require("stream");
const { createReadStream, createWriteStream } = require("fs");
const readStream = createReadStream("./README.md");
const writeStream = createWriteStream("./copy.txt");

const tunnel = new PassThrough();

tunnel.on("data", (chunk) => {
  console.log("bytes:", chunk); 
});

Vectormike

{
  "name": "prime-block",
  "version": "1.0.0",
  "description": "",
  "main": "index.js",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1"
  },
  "keywords": [],
  "author": "",

Vectormike

const Stream = require('stream')

const readableStream = new Stream.Readable({
  read() {}
})

readableStream.push("Data");

Vectormike

const Stream = require('stream');

const writableStream = new Stream.Writable();

writableStream._write = (chunk, encoding, next) => {
  console.log(chunk.toString())
  next()
}

Vectormike

$ command1 | command2  | command3 | command4

Vectormike

const http = require("http");
const fs = require("fs");

const server = http.createServer((req, res) => {
  const stream = fs.createReadStream(__dirname + "/file.txt");
  stream.pipe(res);
});
server.listen(5000);

Vectormike

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

const server = http.createServer((req, res) => {
  fs.readFile(__dirname + '/file.txt', (err, data) => {
    res.end(data)
  })
});

server.listen(5000);

Vectormike

process.on('message', (message) => {
  const response = calculatePrime(message.primeNumber);
  process.send(response);
  process.exit;
});

const calculatePrime = (number) => {
  let start = new Date();
  let end = new Date();