deavmi/tasky
deavmi
/
tasky
mirror of https://github.com/deavmi/tasky.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Make TaskyEvent accessible at the module level

This commit is contained in:
Tristan B. Velloza Kildaire 2022-05-24 20:28:28 +02:00
parent 246adcc1f9
commit 726ad57706
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
source/tasky/engine.d
View File

@ -15,6 +15,22 @@ import std.socket : Socket;
import core.thread : Thread, dur; import core.thread : Thread, dur;
import tasky.exceptions : SessionError; import tasky.exceptions : SessionError;
public class TaskyEvent : Event
{
private byte[] payload;
this(ulong descID, byte[] payload)
{
super(descID);
this.payload = payload;
}
public byte[] getPayload()
{
return payload;
}
}
public final class Engine : Thread public final class Engine : Thread
{ {
/** /**
@ -56,22 +72,6 @@ public final class Engine : Thread
running = true; running = true;
} }
public class TaskyEvent : Event
{
private byte[] payload;
this(ulong descID, byte[] payload)
{
super(descID);
this.payload = payload;
}
public byte[] getPayload()
{
return payload;
}
}
/** /**
* Worker thread function which checks the tristanable * Worker thread function which checks the tristanable
* queues for whichever has messages on them and then * queues for whichever has messages on them and then