}
var net = require('net');
-var Stream = require('stream').Stream;
+var stream = require('stream');
var FreeList = require('freelist').FreeList;
var HTTPParser = process.binding('http_parser').HTTPParser;
/* Abstract base class for ServerRequest and ClientResponse. */
function IncomingMessage (socket) {
- Stream.call(this);
+ stream.Stream.call(this);
// TODO Remove one of these eventually.
this.socket = socket;
this.statusCode = null;
this.client = this.socket;
}
-sys.inherits(IncomingMessage, Stream);
+sys.inherits(IncomingMessage, stream.Stream);
exports.IncomingMessage = IncomingMessage;
IncomingMessage.prototype._parseQueryString = function () {
};
function OutgoingMessage (socket) {
- Stream.call(this);
+ stream.Stream.call(this);
// TODO Remove one of these eventually.
this.socket = socket;
this.finished = false;
}
-sys.inherits(OutgoingMessage, Stream);
+sys.inherits(OutgoingMessage, stream.Stream);
exports.OutgoingMessage = OutgoingMessage;
// This abstract either writing directly to the socket or buffering it.