summaryrefslogtreecommitdiff
path: root/test/parallel/test-http2-zero-length-write.js
diff options
context:
space:
mode:
authorJames M Snell <jasnell@gmail.com>2017-07-17 10:29:42 -0700
committerJames M Snell <jasnell@gmail.com>2017-08-04 12:55:58 -0700
commitb1e055696fbcd4b8829630d0be787cfc74fe913b (patch)
treed0d5be3a2e46ff5a38e139eb519e3aa5322a2d71 /test/parallel/test-http2-zero-length-write.js
parente71e71b5138c3dfee080f4215dd957dc7a6cbdaf (diff)
downloadandroid-node-v8-b1e055696fbcd4b8829630d0be787cfc74fe913b.tar.gz
android-node-v8-b1e055696fbcd4b8829630d0be787cfc74fe913b.tar.bz2
android-node-v8-b1e055696fbcd4b8829630d0be787cfc74fe913b.zip
http2: add tests and benchmarks
PR-URL: https://github.com/nodejs/node/pull/14239 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Diffstat (limited to 'test/parallel/test-http2-zero-length-write.js')
-rw-r--r--test/parallel/test-http2-zero-length-write.js50
1 files changed, 50 insertions, 0 deletions
diff --git a/test/parallel/test-http2-zero-length-write.js b/test/parallel/test-http2-zero-length-write.js
new file mode 100644
index 0000000000..5f4f0681d4
--- /dev/null
+++ b/test/parallel/test-http2-zero-length-write.js
@@ -0,0 +1,50 @@
+// Flags: --expose-http2
+'use strict';
+
+const common = require('../common');
+const assert = require('assert');
+const http2 = require('http2');
+
+const { Readable } = require('stream');
+
+function getSrc() {
+ const chunks = [ '', 'asdf', '', 'foo', '', 'bar', '' ];
+ return new Readable({
+ read() {
+ const chunk = chunks.shift();
+ if (chunk !== undefined)
+ this.push(chunk);
+ else
+ this.push(null);
+ }
+ });
+}
+
+const expect = 'asdffoobar';
+
+const server = http2.createServer();
+server.on('stream', common.mustCall((stream) => {
+ let actual = '';
+ stream.respond();
+ stream.resume();
+ stream.setEncoding('utf8');
+ stream.on('data', (chunk) => actual += chunk);
+ stream.on('end', common.mustCall(() => {
+ getSrc().pipe(stream);
+ assert.strictEqual(actual, expect);
+ }));
+}));
+
+server.listen(0, common.mustCall(() => {
+ const client = http2.connect(`http://localhost:${server.address().port}`);
+ let actual = '';
+ const req = client.request({ ':method': 'POST' });
+ req.on('response', common.mustCall());
+ req.on('data', (chunk) => actual += chunk);
+ req.on('end', common.mustCall(() => {
+ assert.strictEqual(actual, expect);
+ server.close();
+ client.destroy();
+ }));
+ getSrc().pipe(req);
+}));