- Added field `watcher` of type `Watcher`
This commit is contained in:
Tristan B. Velloza Kildaire 2023-03-26 18:24:15 +02:00
parent de44080c6b
commit 80d870e41a
1 changed files with 8 additions and 0 deletions

View File

@ -6,6 +6,7 @@ module tristanable.manager;
import std.socket; import std.socket;
import tristanable.queue : Queue; import tristanable.queue : Queue;
import core.sync.mutex : Mutex; import core.sync.mutex : Mutex;
import tristanable.watcher : Watcher;
/** /**
* Manages a provided socket by spawning * Manages a provided socket by spawning
@ -30,6 +31,13 @@ public class Manager
private Queue[] queues; private Queue[] queues;
private Mutex queuesLock; 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 * Constructs a new manager which will read from
* this socket and file mail for us * this socket and file mail for us