[connect] rename neko -> server package
This commit is contained in:
@@ -1,10 +1,10 @@
|
|||||||
package hw.connect.neko;
|
package hw.connect.server;
|
||||||
|
|
||||||
import hw.Timer;
|
import hw.Timer;
|
||||||
import protohx.Message;
|
import protohx.Message;
|
||||||
import sys.net.Socket;
|
import sys.net.Socket;
|
||||||
|
|
||||||
class NekoConnection<O:Message, I:Message> extends BaseConnection<O, I> {
|
class ServerConnection<O:Message, I:Message> extends BaseConnection<O, I> {
|
||||||
|
|
||||||
public var socket(default, null):Socket;
|
public var socket(default, null):Socket;
|
||||||
|
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
package hw.connect.neko;
|
package hw.connect.server;
|
||||||
|
|
||||||
import com.hurlant.crypto.hash.SHA1;
|
import com.hurlant.crypto.hash.SHA1;
|
||||||
import com.hurlant.util.Base64;
|
import com.hurlant.util.Base64;
|
||||||
@@ -7,7 +7,7 @@ import haxe.io.BytesBuffer;
|
|||||||
import protohx.Message;
|
import protohx.Message;
|
||||||
import sys.net.Socket;
|
import sys.net.Socket;
|
||||||
|
|
||||||
class NekoWSConnection<O:Message, I:Message> extends NekoConnection<O, I> {
|
class ServerWSConnection<O:Message, I:Message> extends ServerConnection<O, I> {
|
||||||
|
|
||||||
private var opened:Bool;
|
private var opened:Bool;
|
||||||
private var buffer:Bytes;
|
private var buffer:Bytes;
|
||||||
@@ -1,8 +1,8 @@
|
|||||||
package hw.connect.session;
|
package hw.connect.session;
|
||||||
|
|
||||||
import haxe.io.Bytes;
|
import haxe.io.Bytes;
|
||||||
import hw.connect.neko.NekoConnection;
|
import hw.connect.server.ServerConnection;
|
||||||
import hw.connect.neko.NekoWSConnection;
|
import hw.connect.server.ServerWSConnection;
|
||||||
import protohx.Message;
|
import protohx.Message;
|
||||||
import sys.net.Socket;
|
import sys.net.Socket;
|
||||||
|
|
||||||
@@ -40,9 +40,9 @@ class ProtoSession<O:Message, I:Message> implements ISession {
|
|||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
if (StringTools.startsWith(str, "GET")) {
|
if (StringTools.startsWith(str, "GET")) {
|
||||||
connection = new NekoWSConnection<O, I>(socket, request);
|
connection = new ServerWSConnection<O, I>(socket, request);
|
||||||
} else {
|
} else {
|
||||||
connection = new NekoConnection<O, I>(socket, request);
|
connection = new ServerConnection<O, I>(socket, request);
|
||||||
}
|
}
|
||||||
connection.receiveHandler.connect(onRequest);
|
connection.receiveHandler.connect(onRequest);
|
||||||
return connection;
|
return connection;
|
||||||
|
|||||||
Reference in New Issue
Block a user