11cb0ef41Sopenharmony_ci'use strict'; 21cb0ef41Sopenharmony_ci 31cb0ef41Sopenharmony_ciconst common = require('../common'); 41cb0ef41Sopenharmony_ciif (!common.hasCrypto) 51cb0ef41Sopenharmony_ci common.skip('missing crypto'); 61cb0ef41Sopenharmony_ciconst assert = require('assert'); 71cb0ef41Sopenharmony_ciconst h2 = require('http2'); 81cb0ef41Sopenharmony_ci 91cb0ef41Sopenharmony_ciconst server = h2.createServer(); 101cb0ef41Sopenharmony_ci 111cb0ef41Sopenharmony_ci// We use the lower-level API here 121cb0ef41Sopenharmony_ciserver.on('stream', common.mustCall((stream, headers, flags) => { 131cb0ef41Sopenharmony_ci let data = ''; 141cb0ef41Sopenharmony_ci stream.setEncoding('utf8'); 151cb0ef41Sopenharmony_ci stream.on('data', (chunk) => data += chunk); 161cb0ef41Sopenharmony_ci stream.on('end', common.mustCall(() => { 171cb0ef41Sopenharmony_ci assert.strictEqual(data, 'some data more data'); 181cb0ef41Sopenharmony_ci })); 191cb0ef41Sopenharmony_ci stream.respond(); 201cb0ef41Sopenharmony_ci stream.end('ok'); 211cb0ef41Sopenharmony_ci})); 221cb0ef41Sopenharmony_ci 231cb0ef41Sopenharmony_ciserver.listen(0, common.mustCall(() => { 241cb0ef41Sopenharmony_ci const client = h2.connect(`http://localhost:${server.address().port}`); 251cb0ef41Sopenharmony_ci 261cb0ef41Sopenharmony_ci const req = client.request({ ':method': 'POST' }); 271cb0ef41Sopenharmony_ci req.write('some data '); 281cb0ef41Sopenharmony_ci req.end('more data'); 291cb0ef41Sopenharmony_ci 301cb0ef41Sopenharmony_ci req.on('response', common.mustCall()); 311cb0ef41Sopenharmony_ci req.resume(); 321cb0ef41Sopenharmony_ci req.on('end', common.mustCall()); 331cb0ef41Sopenharmony_ci req.on('close', common.mustCall(() => { 341cb0ef41Sopenharmony_ci server.close(); 351cb0ef41Sopenharmony_ci client.close(); 361cb0ef41Sopenharmony_ci })); 371cb0ef41Sopenharmony_ci})); 38