|
@@ -37,6 +37,7 @@ class Socket {
|
|
var s : hl.uv.Stream;
|
|
var s : hl.uv.Stream;
|
|
#elseif (nodejs && hxnodejs)
|
|
#elseif (nodejs && hxnodejs)
|
|
var s : js.node.net.Socket;
|
|
var s : js.node.net.Socket;
|
|
|
|
+ var srv : js.node.net.Server;
|
|
#end
|
|
#end
|
|
public var out(default, null) : SocketOutput;
|
|
public var out(default, null) : SocketOutput;
|
|
public var input(default, null) : SocketInput;
|
|
public var input(default, null) : SocketInput;
|
|
@@ -105,7 +106,7 @@ class Socket {
|
|
throw e;
|
|
throw e;
|
|
}
|
|
}
|
|
#elseif (nodejs && hxnodejs)
|
|
#elseif (nodejs && hxnodejs)
|
|
- js.node.Net.createServer(function(sock) {
|
|
|
|
|
|
+ srv = js.node.Net.createServer(function(sock) {
|
|
var s = new Socket();
|
|
var s = new Socket();
|
|
s.s = sock;
|
|
s.s = sock;
|
|
s.s.on('error', function(e) {
|
|
s.s.on('error', function(e) {
|
|
@@ -119,7 +120,8 @@ class Socket {
|
|
}).on('error', function(e) {
|
|
}).on('error', function(e) {
|
|
close();
|
|
close();
|
|
onError(e);
|
|
onError(e);
|
|
- }).listen(port, host, listenCount);
|
|
|
|
|
|
+ });
|
|
|
|
+ srv.listen(port, host, listenCount);
|
|
#else
|
|
#else
|
|
throw "Not implemented";
|
|
throw "Not implemented";
|
|
#end
|
|
#end
|
|
@@ -139,6 +141,10 @@ class Socket {
|
|
out = new SocketOutput();
|
|
out = new SocketOutput();
|
|
s = null;
|
|
s = null;
|
|
}
|
|
}
|
|
|
|
+ if( srv != null ) {
|
|
|
|
+ srv.close();
|
|
|
|
+ srv = null;
|
|
|
|
+ }
|
|
#end
|
|
#end
|
|
}
|
|
}
|
|
|
|
|