Change 'new node.tcp.Connection' to 'node.tcp.createConnection'

This commit is contained in:
Ryan 2009-06-30 13:56:52 +02:00
parent d56552dc66
commit 8047b912c0
5 changed files with 17 additions and 17 deletions

View File

@ -11,6 +11,12 @@ node.createProcess = function (command) {
return process; return process;
}; };
node.tcp.createConnection = function (port, host) {
var connection = new node.tcp.Connection();
connection.connect(port, host);
return connection;
};
// Timers // Timers
function setTimeout (callback, after) { function setTimeout (callback, after) {

View File

@ -33,8 +33,10 @@ function onLoad() {
}).listen(port); }).listen(port);
var c = new node.tcp.Connection(); var c = node.tcp.createConnection(port);
c.setEncoding("utf8"); c.setEncoding("utf8");
c.addListener("connect", function () { c.addListener("connect", function () {
c.send( "GET /hello HTTP/1.1\r\n\r\n" ); c.send( "GET /hello HTTP/1.1\r\n\r\n" );
requests_sent += 1; requests_sent += 1;
@ -58,8 +60,6 @@ function onLoad() {
c.addListener("disconnect", function () { c.addListener("disconnect", function () {
assertEquals(c.readyState, "closed"); assertEquals(c.readyState, "closed");
}); });
c.connect(port);
} }
function onExit () { function onExit () {

View File

@ -22,10 +22,13 @@ function onLoad () {
}); });
}); });
server.listen(port); server.listen(port);
var client = new node.tcp.Connection();
var client = node.tcp.createConnection(port);
client.setEncoding("UTF8"); client.setEncoding("UTF8");
client.addListener("connect", function () { client.addListener("connect", function () {
puts("client connected.");
}); });
client.addListener("receive", function (chunk) { client.addListener("receive", function (chunk) {
@ -41,8 +44,6 @@ function onLoad () {
else else
server.close(); server.close();
}); });
client.connect(port);
} }
function onExit () { function onExit () {

View File

@ -40,8 +40,7 @@ function pingPongTest (port, host, on_complete) {
}); });
server.listen(port, host); server.listen(port, host);
var client = new node.tcp.Connection(); var client = node.tcp.createConnection(port, host);
assertEquals("closed", client.readyState);
client.setEncoding("utf8"); client.setEncoding("utf8");
@ -76,9 +75,6 @@ function pingPongTest (port, host, on_complete) {
if (on_complete) on_complete(); if (on_complete) on_complete();
tests_run += 1; tests_run += 1;
}); });
assertEquals("closed", client.readyState);
client.connect(port, host);
} }
function onLoad () { function onLoad () {

View File

@ -952,12 +952,9 @@ socket for +node.tcp.Server+.
(TODO: access error codes.) (TODO: access error codes.)
|========================================================= |=========================================================
+new node.tcp.Connection()+:: +node.tcp.createConnection(port, host="127.0.0.1")+::
Creates a new connection object. Creates a new connection object and
opens a connection to the specified +port+ and
+connection.connect(port, host="127.0.0.1")+::
Opens a connection to the specified +port+ and
+host+. If the second parameter is omitted, localhost is +host+. If the second parameter is omitted, localhost is
assumed. assumed.