}
function Stream (fd, type) {
+ if (!(this instanceof Stream)) return new Stream(fd, type);
events.EventEmitter.call(this);
this.fd = null;
function Server (listener) {
+ if (!(this instanceof Server)) return new Server(listener);
events.EventEmitter.call(this);
var self = this;
common = require("../common");
assert = common.assert
-tcp = require("tcp");
+net = require("net");
binaryString = "";
for (var i = 255; i >= 0; i--) {
binaryString += S;
}
-var echoServer = tcp.createServer(function (connection) {
+// safe constructor
+var echoServer = net.Server(function (connection) {
connection.setEncoding("binary");
connection.addListener("data", function (chunk) {
common.error("recved: " + JSON.stringify(chunk));
echoServer.addListener("listening", function() {
var j = 0;
- var c = tcp.createConnection(common.PORT);
+ var c = net.createConnection(common.PORT);
c.setEncoding("binary");
c.addListener("data", function (chunk) {