|
|
@ -46,9 +46,16 @@ utcDate._onTimeout = function() { |
|
|
|
function OutgoingMessage() { |
|
|
|
Stream.call(this); |
|
|
|
|
|
|
|
// Queue that holds all currently pending data, until the response will be
|
|
|
|
// assigned to the socket (until it will its turn in the HTTP pipeline).
|
|
|
|
this.output = []; |
|
|
|
this.outputEncodings = []; |
|
|
|
this.outputCallbacks = []; |
|
|
|
|
|
|
|
// `outputSize` is an approximate measure of how much data is queued on this
|
|
|
|
// response. `_onPendingData` will be invoked to update similar global
|
|
|
|
// per-connection counter. That counter will be used to pause/unpause the
|
|
|
|
// TCP socket and HTTP Parser and thus handle the backpressure.
|
|
|
|
this.outputSize = 0; |
|
|
|
|
|
|
|
this.writable = true; |
|
|
|