diff --git a/source/tristanable/manager.d b/source/tristanable/manager.d index bf6f85a..862d8bd 100644 --- a/source/tristanable/manager.d +++ b/source/tristanable/manager.d @@ -6,6 +6,7 @@ module tristanable.manager; import std.socket; import tristanable.queue : Queue; import core.sync.mutex : Mutex; +import tristanable.watcher : Watcher; /** * Manages a provided socket by spawning @@ -30,6 +31,13 @@ public class Manager private Queue[] queues; private Mutex queuesLock; + /** + * Watcher which manages the socket and + * enqueues new messages into the respective + * quueue for us + */ + private Watcher watcher; + /** * Constructs a new manager which will read from * this socket and file mail for us