Req Readable

A server request is a Node Readable: consume the body with `for await (const chunk of req)` — or req.on('data'/'end'), or req.pipe(dest) — instead of buffering req.body. Self-contained: the server consumes a POSTed body chunk-at-a-time, and an in-process http.request drives it, then the process exits. Runs the same way under Node.js.

import http from 'http';

http.createServer(async (req: http.IncomingMessage, res: http.ServerResponse) => {
  let total = 0;
  let chunks = 0;
  for await (const chunk of req) {
    total = total + chunk.length; // chunk is a Uint8Array
    chunks = chunks + 1;
  }
  res.end('received ' + total + ' bytes in ' + chunks + ' chunk(s)');
}).listen(18524, () => {
  const creq = http.request({ port: 18524, path: '/', method: 'POST' }, (res) => {
    let body = '';
    res.on('data', (c: string) => { body = body + c; });
    res.on('end', () => {
      console.log(body);
      process.exit(0);
    });
  });
  creq.write('a streamed request body, consumed as a Node Readable');
  creq.end();
});

View source on GitHubexamples/http/req_readable.ts

← Req Pipe Res Res Backpressure Drain →