Queue

- Removed `TListener` references Everything else - Removed reference to old/duplicate `queue.d` module
deavmi · Oct 2, 2023 · 5cafbb8 · 5cafbb8
1 parent be91f5f
commit 5cafbb8
Show file tree

Hide file tree

Showing 5 changed files with 3 additions and 253 deletions.
diff --git a/source/tristanable/manager/manager.d b/source/tristanable/manager/manager.d
@@ -4,7 +4,7 @@
 module tristanable.manager.manager;
 
 import std.socket;
-import tristanable.queue : Queue;
+import tristanable.queue.queue : Queue;
 import core.sync.mutex : Mutex;
 import tristanable.manager.watcher : Watcher;
 import tristanable.encoding : TaggedMessage;

diff --git a/source/tristanable/manager/watcher.d b/source/tristanable/manager/watcher.d
@@ -11,7 +11,7 @@ import std.socket;
 import bformat;
 import tristanable.encoding;
 import tristanable.exceptions;
-import tristanable.queue;
+import tristanable.queue.queue;
 import bformat.client;
 
 /** 

diff --git a/source/tristanable/package.d b/source/tristanable/package.d
@@ -12,7 +12,7 @@ public import tristanable.manager;
 /**
  * A queue of queue items all of the same tag
  */
-public import tristanable.queue : Queue;
+public import tristanable.queue.queue : Queue;
 
 /**
  * Error handling type definitions

diff --git a/source/tristanable/queue.d b/source/tristanable/queue.d
diff --git a/source/tristanable/queue/queue.d b/source/tristanable/queue/queue.d
@@ -3,8 +3,6 @@
  */
 module tristanable.queue.queue;
 
-import tristanable.queue.listener : TListener;
-
 import core.sync.mutex : Mutex;
 import core.sync.condition : Condition;
 import core.sync.exception : SyncError;
@@ -54,16 +52,6 @@ public class Queue
      */
     private Mutex queueLock;
 
-    /** 
-     * Attached queue listeners
-     */
-    private SList!(TListener) listeners;
-
-    /** 
-     * Lock for the listeners queue
-     */
-    private Mutex listenersLock;
-
     /**
      * If a message is enqueued prior
      * to us sleeping then we won't