deavmi/nostril
deavmi/nostril
1
0
Fork 0
mirror of https://github.com/deavmi/nostril synced 2024-09-20 01:43:26 +02:00
Code Issues Packages Projects Releases Wiki Activity

Testing

Browse Source
This commit is contained in:
Tristan B. Velloza Kildaire 2023-03-04 17:11:13 +02:00
parent c35d9cf2b6
commit b0b9e6b7ff
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
source/nostril/server.d
View File

@ -65,11 +65,27 @@ public class Server
router.get("/", this.websocketNegotiater); router.get("/", this.websocketNegotiater);
} }
private void tcpHandler(TCPConnection tcpClient)
{
}
/** /**
* TODO * TODO
*/ */
public void startServer() public void startServer()
{ {
import eventcore.socket;
import std.socket;
// StreamListenSocket servSock = listenStream(parseAddress("[::]", 8082));
// TCPListenOptions d;
// TCPListener serverSocket = listenTCP(httpSettings.port, &tcpHandler, httpSettings.bindAddresses[0]);
// Bind the router to the server // Bind the router to the server
// TODO: Investigate multi-threaded listener rather // TODO: Investigate multi-threaded listener rather
listenHTTP(httpSettings, router); listenHTTP(httpSettings, router);
@ -183,6 +199,8 @@ public class Connection : Fiber
try try
{ {
// TODO: We could juist cal, this (I presume - I must check)
// ... that this is async I/O fiber vibe (then no need for yield() at end)
data = socket.receiveText(); data = socket.receiveText();
} }
/* On connection error or format error */ /* On connection error or format error */