parent
1336a37d13
commit
c6611fc26b
|
@ -1,37 +0,0 @@
|
||||||
module tristanable.watcher;
|
|
||||||
|
|
||||||
import core.thread : Thread;
|
|
||||||
import tristanable.manager : Manager;
|
|
||||||
import std.socket;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Watches the socket on a thread of its own,
|
|
||||||
* performs the decoding of the incoming messages
|
|
||||||
* and places them into the correct queues via
|
|
||||||
* the associated Manager instance
|
|
||||||
*/
|
|
||||||
public class Watcher : Thread
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* The associated manager to use
|
|
||||||
* such that we can place new mail
|
|
||||||
* into their respective inboxes (queues)
|
|
||||||
*/
|
|
||||||
private Manager manager;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* The underlying socket to read from
|
|
||||||
*/
|
|
||||||
private Socket socket;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
private void watch()
|
|
||||||
{
|
|
||||||
while(true)
|
|
||||||
{
|
|
||||||
// TODO: Implement me
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue