Added thread safe watcher (and also multithreaded it)

example/client/dub.selections.json

@@ -2,6 +2,6 @@
 	"fileVersion": 1,
 	"versions": {
 		"bformat": "1.0.8",
-		"tristanable": "0.0.23"
+		"tristanable": "0.0.24"
 	}
 }

example/client/source/app.d

@@ -1,6 +1,7 @@
 import std.stdio;
 import tristanable.manager : Manager;
 import std.socket;
+import core.thread;
 
 void main()
 {
@@ -9,6 +10,29 @@ void main()
 	socket.connect(parseAddress("127.0.0.1",7777));
 	Manager manager = new Manager(socket);
 
+	class bruh : Thread
+	{
+		this()
+		{
+			super(&run);
+		}
+
+		private void run()
+		{
+			while(true)
+			{
+				manager.lockQueue();
+				writeln(manager.getQueue());
+				manager.unlockQueue();
+				import core.thread;
+
+				Thread.sleep(dur!("seconds")(1));
+			}
+		}
+	}
+
+	new bruh().start();
+
 	manager.sendMessage(69, [77]);
 	manager.sendMessage(70, [78]);
 
@@ -25,13 +49,9 @@ void main()
 	writeln(receivedKaka);
 
 
-	while(true)
-	{
-		writeln(manager.getQueue());
-		import core.thread;
+	
 
-		Thread.sleep(dur!("seconds")(10));
-	}
+	
 	
 	
 

example/server/dub.selections.json

@@ -2,6 +2,6 @@
 	"fileVersion": 1,
 	"versions": {
 		"bformat": "1.0.8",
-		"tristanable": "0.0.23"
+		"tristanable": "0.0.24"
 	}
 }

example/server/source/app.d

@@ -2,6 +2,7 @@ import std.stdio;
 import std.socket;
 import tristanable.encoding : DataMessage;
 import bmessage;
+import core.thread;
 
 void main()
 {
@@ -26,6 +27,7 @@ void main()
 		sendMessage(conn, d.encode());
 
 		d = new DataMessage(69, [1]);
+		Thread.sleep(dur!("seconds")(5));
 		sendMessage(conn, d.encode());
 	}