| 'use strict'; |
| |
| const common = require('../common'); |
| if (!common.hasCrypto) |
| common.skip('missing crypto'); |
| const assert = require('assert'); |
| const h2 = require('http2'); |
| |
| // Check that drain event is passed from Http2Stream |
| |
| const testString = 'tests'; |
| |
| const server = h2.createServer(); |
| |
| server.on('request', common.mustCall((req, res) => { |
| res.stream._writableState.highWaterMark = testString.length; |
| assert.strictEqual(res.write(testString), false); |
| res.on('drain', common.mustCall(() => res.end(testString))); |
| })); |
| |
| server.listen(0, common.mustCall(() => { |
| const port = server.address().port; |
| |
| const client = h2.connect(`http://localhost:${port}`); |
| const request = client.request({ |
| ':path': '/foobar', |
| ':method': 'POST', |
| ':scheme': 'http', |
| ':authority': `localhost:${port}` |
| }); |
| request.resume(); |
| request.end(); |
| |
| let data = ''; |
| request.setEncoding('utf8'); |
| request.on('data', (chunk) => (data += chunk)); |
| |
| request.on('end', common.mustCall(function() { |
| assert.strictEqual(data, testString.repeat(2)); |
| client.close(); |
| server.close(); |
| })); |
| })); |