websocket-stream does not handle backpressure

index.js

'use strict';

const WebSocket = require('ws');
const websocketStream = require('websocket-stream');
const { Readable, Writable } = require('stream');

const chunk = Buffer.alloc(1024);

const src = new Readable({
  read() {
    this.push(chunk);
  }
});

const dest = new Writable({
  write(chunk, encoding, callback) {
    setTimeout(callback, 10);
  }
});

const server = new WebSocket.Server({ port: 0 }, function() {
  const { port } = this.address();
  const ws = websocketStream(`ws://localhost:${port}`);

  ws.pipe(dest);
});

server.on('connection', function(ws) {
  const dest = new Writable({
    write(chunk, encoding, callback) {
      ws.send(chunk, callback);
    }
  });

  src.pipe(dest);
});

setInterval(function() {
  console.log(process.memoryUsage());
}, 1000);