stream-browserify

Creating a Readable Stream

This code sample demonstrates how to create a readable stream that emits data from an array. Each chunk of data is pushed to the stream and logged to the console when the 'data' event is emitted.

const Stream = require('stream-browserify');
let data = ['stream', 'browserify'];
let readable = Stream.Readable({
  read(size) {
    if (data.length === 0) this.push(null);
    else this.push(data.shift());
  }
});
readable.on('data', (chunk) => {
  console.log(chunk.toString());
});

Creating a Writable Stream

This code sample shows how to create a writable stream that logs any data written to it to the console.

const Stream = require('stream-browserify');
let writable = new Stream.Writable({
  write(chunk, encoding, callback) {
    console.log(chunk.toString());
    callback();
  }
});
writable.write('Hello, world!');

Piping Streams

This example demonstrates how to pipe data from a readable stream directly into a writable stream. The data from the readable stream is logged to the console as it's written to the writable stream.

const Stream = require('stream-browserify');
let readable = Stream.Readable.from(['stream', 'browserify']);
let writable = new Stream.Writable({
  write(chunk, encoding, callback) {
    console.log(chunk.toString());
    callback();
  }
});
readable.pipe(writable);

Transform Stream

This code sample illustrates how to create a transform stream that converts any input data to uppercase. The transform stream is piped from stdin and then piped to stdout, effectively creating a stream that uppercases input from the command line.

const Stream = require('stream-browserify');
let transform = new Stream.Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});
process.stdin.pipe(transform).pipe(process.stdout);