| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 42b4f3c commit 6bfdba1
2 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -37,7 +37,7 @@ const { OutgoingMessage } = require('_http_outgoing'); | |||
| 37 | 37 | const Agent = require('_http_agent'); | |
| 38 | 38 | const { Buffer } = require('buffer'); | |
| 39 | 39 | const { urlToOptions, searchParamsSymbol } = require('internal/url'); | |
| 40 | - const { outHeadersKey } = require('internal/http'); | ||
| 40 | + const { outHeadersKey, ondrain } = require('internal/http'); | ||
| 41 | 41 | const { nextTick } = require('internal/process/next_tick'); | |
| 42 | 42 | ||
| 43 | 43 | // The actual list of disallowed characters in regexp form is more like: | |
@@ -452,6 +452,7 @@ function socketOnData(d) { | |||
| 452 | 452 | ||
| 453 | 453 | socket.removeListener('data', socketOnData); | |
| 454 | 454 | socket.removeListener('end', socketOnEnd); | |
| 455 | + socket.removeListener('drain', ondrain); | ||
| 455 | 456 | parser.finish(); | |
| 456 | 457 | freeParser(parser, req, socket); | |
| 457 | 458 | ||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -67,6 +67,7 @@ server.listen(0, common.mustCall(() => { | |||
| 67 | 67 | assert.strictEqual(socket._httpMessage, null); | |
| 68 | 68 | assert.strictEqual(socket.listeners('connect').length, 0); | |
| 69 | 69 | assert.strictEqual(socket.listeners('data').length, 0); | |
| 70 | + assert.strictEqual(socket.listeners('drain').length, 0); | ||
| 70 | 71 | ||
| 71 | 72 | // the stream.Duplex onend listener | |
| 72 | 73 | // allow 0 here, so that i can run the same test on streams1 impl | |
| Back | FazBrowse Home | New Git URL |
0 commit comments