Update benchmarks

README.md

@@ -18,6 +18,20 @@ Picture of Eleven
 npm i undici
 ```
 
+## Benchmarks
+
+Machine: Intel i7-7700k, 4.5GHz, 4C/8T, 32GB RAM, NVMe SSD
+Server: [H2O](https://github.com/h2o/h2o) 2.2.5
+Configuration: HTTP/1.1 without TLS
+
+```
+undici - stream - pipe x 24,409 ops/sec ±1.70% (85 runs sampled)
+undici - request - pipe x 23,060 ops/sec ±1.11% (88 runs sampled)
+http - keepalive - pipe x 15,749 ops/sec ±3.18% (77 runs sampled)
+```
+
+The benchmark is a simple `hello world` [example](benchmarks/index.js).
+
 ## API
 
 <a name='client'></a>

benchmarks/index.js

@@ -0,0 +1,84 @@
+'use strict'
+const { PassThrough } = require('stream')
+const http = require('http')
+const Benchmark = require('benchmark')
+const undici = require('..')
+
+// # Start the h2o server (in h2o repository)
+// # Then change the port below to 8080
+// h2o -c examples/h2o/h2o.conf
+//
+// # Alternatively start the Node.js server
+// node benchmarks/server.js
+//
+// # Start the benchmarks
+// node benchmarks/index.js
+
+const httpOptions = {
+ protocol: 'http:',
+ hostname: 'localhost',
+ method: 'GET',
+ path: '/',
+ port: 3000,
+ agent: new http.Agent({ keepAlive: true })
+}
+
+const undiciOptions = {
+ path: '/',
+ method: 'GET'
+}
+
+const pool = undici(`https://${httpOptions.hostname}:${httpOptions.port}`, {
+ connections: 100,
+ pipelining: 10
+})
+
+const suite = new Benchmark.Suite()
+
+suite.add('undici - request - pipe', {
+ defer: true,
+ fn: deferred => {
+ pool.request(undiciOptions, (error, { body }) => {
+ if (error) {
+ throw error
+ }
+
+ const stream = new PassThrough()
+ stream.once('finish', () => {
+ deferred.resolve()
+ })
+
+ body.pipe(stream)
+ })
+ }
+}).add('undici - stream - pipe', {
+ defer: true,
+ fn: deferred => {
+ pool.stream(undiciOptions, () => {
+ const stream = new PassThrough()
+ stream.once('finish', () => {
+ deferred.resolve()
+ })
+
+ return stream
+ }, error => {
+ if (error) {
+ throw error
+ }
+ })
+ }
+}).add('http - keepalive - pipe', {
+ defer: true,
+ fn: deferred => {
+ http.get(httpOptions, response => {
+ const stream = new PassThrough()
+ stream.once('finish', () => {
+ deferred.resolve()
+ })
+
+ response.pipe(stream)
+ })
+ }
+}).on('cycle', event => {
+ console.log(String(event.target))
+}).run()

package.json

@@ -17,6 +17,7 @@
  },
  "homepage": "https://github.com/mcollina/undici#readme",
  "devDependencies": {
+ "benchmark": "^2.1.4",
  "https-pem": "^2.0.0",
  "pre-commit": "^1.2.2",
  "proxyquire": "^2.0.1",