dispose local disposable in unittest

FuturistiCoder · Aug 25, 2020 · 32e0f38 · 32e0f38
1 parent 4b5d9b3
commit 32e0f38
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/LiteDB.Realtime.Test/Database/RealtimeLiteDatabase_Should.cs b/LiteDB.Realtime.Test/Database/RealtimeLiteDatabase_Should.cs
@@ -48,9 +48,9 @@ public void Notify_Collection_Subscription_When_A_New_Data_Added()
             List<Item> receivedItems = null;
             int rawOnNextCount = 0;
             // collection subscription
-            db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
+            using var colSub = db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
             // collection raw subscription
-            db.Realtime.Collection<Item>("items").Raw.Subscribe(liteCollection => rawOnNextCount++);
+            using var rawColSub = db.Realtime.Collection<Item>("items").Raw.Subscribe(liteCollection => rawOnNextCount++);
 
             //waiting for notification
             Thread.Sleep(TimeSpan.FromSeconds(1));
@@ -84,9 +84,9 @@ public void Notify_Collection_Subscription_When_A_Data_Upserted()
             List<Item> receivedItems = null;
             int rawOnNextCount = 0;
             // collection subscription
-            db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
+            using var colSub = db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
             // collection raw subscription
-            db.Realtime.Collection<Item>("items").Raw.Subscribe(liteCollection => rawOnNextCount++);
+            using var rawColSub = db.Realtime.Collection<Item>("items").Raw.Subscribe(liteCollection => rawOnNextCount++);
 
             //waiting for notification
             Thread.Sleep(TimeSpan.FromSeconds(1));
@@ -143,10 +143,10 @@ public void Notify_Docuemnt_And_Collection_Subscription_When_The_Document_Modifi
             newItem.Id = newId.AsGuid;
 
             // docuement subscription
-            db.Realtime.Collection<Item>("items").Id(newId).Subscribe(item => receivedItem = item);
+            using var docSub = db.Realtime.Collection<Item>("items").Id(newId).Subscribe(item => receivedItem = item);
 
             // collection subscription
-            db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
+            using var colSub = db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
 
             // waiting for notification
             Thread.Sleep(TimeSpan.FromSeconds(1));
@@ -200,9 +200,9 @@ public void Notify_Document_And_Collection_Subscription_When_Broadcasting()
             newItem.Id = newId.AsGuid;
 
             // docuement subscription
-            db.Realtime.Collection<Item>("items").Id(newId).Subscribe(item => receivedItem = item);
+            using var docSub = db.Realtime.Collection<Item>("items").Id(newId).Subscribe(item => receivedItem = item);
             // collection subscription
-            db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
+            using var colSub = db.Realtime.Collection<Item>("items").Subscribe(items => receivedItems = items);
 
             // waiting for notification
             Thread.Sleep(TimeSpan.FromSeconds(1));
@@ -246,7 +246,7 @@ public void Notify_Null_Document_If_Id_Does_Not_Exist_When_Subscribing()
         {
             using var db = new RealtimeLiteDatabase(new MemoryStream());
             bool isNull = false;
-            db.Realtime.Collection<Item>("items").Id(new BsonValue(Guid.NewGuid())).Subscribe(item => isNull = item is null);
+            using var docSub = db.Realtime.Collection<Item>("items").Id(new BsonValue(Guid.NewGuid())).Subscribe(item => isNull = item is null);
 
             // waiting for notification
             Thread.Sleep(TimeSpan.FromSeconds(1));
@@ -261,7 +261,7 @@ public void Notify_Document_When_A_New_Data_Added()
             var id = Guid.NewGuid();
             using var db = new RealtimeLiteDatabase(new MemoryStream());
             Item receivedItem = new Item();
-            db.Realtime.Collection<Item>("items").Id(new BsonValue(id)).Subscribe(item => receivedItem = item);
+            using var docSub = db.Realtime.Collection<Item>("items").Id(new BsonValue(id)).Subscribe(item => receivedItem = item);
 
             // waiting for notification
             Thread.Sleep(TimeSpan.FromSeconds(1));