Adding tests

example/client/.gitignore

@@ -0,0 +1,15 @@
+.dub
+docs.json
+__dummy.html
+docs/
+/example
+example.so
+example.dylib
+example.dll
+example.a
+example.lib
+example-test-*
+*.exe
+*.o
+*.obj
+*.lst

example/client/dub.json

@@ -0,0 +1,12 @@
+{
+	"authors": [
+		"Tristan B. Kildaire"
+	],
+	"copyright": "Copyright © 2020, Tristan B. Kildaire",
+	"dependencies": {
+		"tristanable": "~>0.0.10"
+	},
+	"description": "A minimal D application.",
+	"license": "proprietary",
+	"name": "example"
+}

example/client/dub.selections.json

@@ -0,0 +1,7 @@
+{
+	"fileVersion": 1,
+	"versions": {
+		"bformat": "1.0.8",
+		"tristanable": "0.0.10"
+	}
+}

example/client/source/app.d

@@ -0,0 +1,11 @@
+import std.stdio;
+import tristanable.manager : Manager;
+import std.socket;
+
+void main()
+{
+	writeln("Edit source/app.d to start your project.");
+	Socket socket = new Socket(AddressFamily.INET, SocketType.STREAM, ProtocolType.TCP);
+	socket.connect(parseAddress("127.0.0.1",7777));
+	Manager manager = new Manager(socket);
+}

example/server/.gitignore

@@ -0,0 +1,15 @@
+.dub
+docs.json
+__dummy.html
+docs/
+/server
+server.so
+server.dylib
+server.dll
+server.a
+server.lib
+server-test-*
+*.exe
+*.o
+*.obj
+*.lst

example/server/dub.json

@@ -0,0 +1,9 @@
+{
+	"authors": [
+		"Tristan B. Kildaire"
+	],
+	"copyright": "Copyright © 2020, Tristan B. Kildaire",
+	"description": "A minimal D application.",
+	"license": "proprietary",
+	"name": "server"
+}

example/server/source/app.d

@@ -0,0 +1,14 @@
+import std.stdio;
+import std.socket;
+
+void main()
+{
+	writeln("Edit source/app.d to start your project.");
+	Socket socket = new Socket(AddressFamily.INET, SocketType.STREAM, ProtocolType.TCP);
+	socket.bind(parseAddress("127.0.0.1",7777));
+	socket.listen(1);
+	while(true)
+	{
+		socket.accept();
+	}
+}

source/tristanable/manager.d

@@ -47,7 +47,7 @@ public final class Manager
         watcher = new Watcher(this, endpoint);
 
         /* Create the garbage collector */
-        gc = new GarbageCollector(this);
+        //gc = new GarbageCollector(this);
 
         /* Initialize the `requestQueue` mutex */
         queueMutex = new Mutex();
@@ -56,7 +56,7 @@ public final class Manager
         watcher.start();
 
         /* Start the garbage collector */
-        gc.start();
+        //gc.start();
     }
 
     public void sendMessage(ulong tag, byte[] data)