deavmi/nostril
deavmi/nostril
1
0
Fork 0
mirror of https://github.com/deavmi/nostril synced 2024-09-19 17:42:56 +02:00
Code Issues Packages Projects Releases Wiki Activity

Server

Browse Source 
- Undid the check for data, I don't believe the `receiveTExt()` blocks forever?, We will Have to see
This commit is contained in:
Tristan B. Velloza Kildaire 2023-03-04 17:42:14 +02:00
parent 617a4507cc
commit f7ec2321b6
1 changed files with 25 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
source/nostril/server.d
View File

@ -172,38 +172,33 @@ public class Connection : Fiber
*/
while(socket.connected() && !hadError)
{
/**
* Check if there is data received and then process it
*/
if(socket.dataAvailableForRead())
/* The received data */
string data;
try
{
/* The received data */
string data;
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();
}
/* On connection error or format error */
catch(WebSocketException e)
{
logger.error("Error in receive text");
hadError = true;
continue;
}
try
{
handler(data);
}
catch(Exception e)
{
logger.error("Error in handler");
}
// 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();
}
/* On connection error or format error */
catch(WebSocketException e)
{
logger.error("Error in receive text");
hadError = true;
continue;
}
try
{
handler(data);
}
catch(Exception e)
{
logger.error("Error in handler");
}