Test specifications implement IDisposable (#154)

Author: joshkempner

src/ReactiveDomain.Testing/ReactiveDomain.Testing.csproj.DotSettings

@@ -0,0 +1,2 @@
+<wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:Boolean x:Key="/Default/CodeInspection/NamespaceProvider/NamespaceFoldersToSkip/=specifications/@EntryIndexedValue">True</s:Boolean></wpf:ResourceDictionary>

src/ReactiveDomain.Testing/Specifications/DispatcherSpecification.cs

@@ -4,7 +4,7 @@
 
 namespace ReactiveDomain.Testing
 {
-    public abstract class DispatcherSpecification
+    public abstract class DispatcherSpecification : IDisposable
     {
         public readonly IDispatcher Dispatcher;
         public readonly IDispatcher LocalBus;
@@ -16,5 +16,25 @@ protected DispatcherSpecification()
             LocalBus = new Dispatcher("Fixture LocalBus");
             TestQueue = new TestQueue(Dispatcher, new[] { typeof(Event), typeof(Command) });
         }
+
+        private bool _disposed;
+        protected virtual void Dispose(bool disposing)
+        {
+            if (_disposed)
+                return;
+            if (disposing)
+            {
+                Dispatcher?.Dispose();
+                LocalBus?.Dispose();
+                TestQueue?.Dispose();
+            }
+            _disposed = true;
+        }
+
+        public void Dispose()
+        {
+            Dispose(true);
+            GC.SuppressFinalize(this);
+        }
     }
 }

src/ReactiveDomain.Testing/Specifications/MockRepositorySpecification.cs

@@ -15,8 +15,7 @@ public class MockRepositorySpecification : DispatcherSpecification
         public IEventSerializer EventSerializer { get; }
         public IConfiguredConnection ConfiguredConnection { get; }
 
-        private string _schema;
-        public string Schema => _schema;
+        public string Schema { get; }
 
         /// <summary>
         /// Creates a mock repository.
@@ -25,7 +24,7 @@ public class MockRepositorySpecification : DispatcherSpecification
         /// <param name="dataStore">Stream store connection.</param>
         private MockRepositorySpecification(string schema, IStreamStoreConnection dataStore)
         {
-            _schema = schema;
+            Schema = schema;
             StreamNameBuilder = string.IsNullOrEmpty(schema) ? new PrefixedCamelCaseStreamNameBuilder() : new PrefixedCamelCaseStreamNameBuilder(schema);
             StreamStoreConnection = dataStore;
             StreamStoreConnection.Connect();
@@ -47,17 +46,13 @@ private MockRepositorySpecification(string schema, IStreamStoreConnection dataSt
         /// Creates a mock repository with a prefix.
         /// </summary>
         /// <param name="schema">Schema prefix for stream name. Default value is "Test".</param>
-        public MockRepositorySpecification(string schema = "Test") : this(schema, new MockStreamStoreConnection(schema))
-        {
-        }
+        public MockRepositorySpecification(string schema = "Test") : this(schema, new MockStreamStoreConnection(schema)) { }
 
         /// <summary>
         /// Creates a mock repository connected to a StreamStore. 
         /// </summary>
         /// <param name="dataStore">Stream store connection.</param>
-        public MockRepositorySpecification(IStreamStoreConnection dataStore) : this(dataStore.ConnectionName, dataStore)
-        {
-        }
+        public MockRepositorySpecification(IStreamStoreConnection dataStore) : this(dataStore.ConnectionName, dataStore) { }
 
         public virtual void ClearQueues()
         {
@@ -71,5 +66,19 @@ public IListener GetListener(string name) =>
                                 StreamStoreConnection,
                                 StreamNameBuilder,
                                 EventSerializer);
+
+        private bool _disposed;
+        protected override void Dispose(bool disposing)
+        {
+            if (_disposed)
+                return;
+            if (disposing)
+            {
+                StreamStoreConnection.Dispose();
+                RepositoryEvents.Dispose();
+            }
+            _disposed = true;
+            base.Dispose(disposing);
+        }
     }
 }

src/ReactiveDomain.Testing/Specifications/MockRepositoryTests.cs

@@ -21,6 +21,7 @@ public MockRepositoryTests()
         public void Dispose()
         {
             _fixture.Dispatcher.Unsubscribe<TestCommands.Command1>(this);
+            _fixture.Dispose();
         }
         [Fact]
         public void can_get_repository_events()