ofReadableStream / ofWritableStream

These functions create wrappers for Readable/Writable NodeJS Streams.
ofReadableStream and ofWritableStream respect back-pressure mechanism of NodeJS Streams.
This example will allow reading 1 byte (highWaterMark: 1) of the script at one time, then it is piped through asynchronous transformation with mapAsync that will not really transform the data, but rather defer passing it along by 32 ms if a character is not a space. Lastly it gets to stdout as it subscribes whole pipeline. This gives an effect of letters appear in terminal one by one.
1
import { createReadStream } from "fs";
2
import { mapAsync, timeout } from "@hullo/core";
3
import { ofReadableStream, ofWritableStream } from "@hullo/node";
4
​
5
const fileContents = ofReadableStream(
6
  createReadStream(__filename, {
7
    highWaterMark: 1
8
  })
9
);
10
​
11
const stdout = ofWritableStream(process.stdout);
12
​
13
fileContents
14
  .pipe(
15
    mapAsync(async data => {
16
      await timeout(data === " " ? 0 : 32);
17
      return data;
18
    })
19
  )
20
  .subscribe(stdout);
Copied!

createRequestListener

Last modified 3yr ago

Copy link