general dispose

redis · Sep 13, 2023 · 74b0c13 · 74b0c13
1 parent 3476abb
commit 74b0c13
Show file tree

Hide file tree

Showing 20 changed files with 5 additions and 94 deletions.
diff --git a/tests/NRedisStack.Tests/AbstractNRedisStackTest.cs b/tests/NRedisStack.Tests/AbstractNRedisStackTest.cs
@@ -43,6 +43,11 @@ protected internal static List<TimeSeriesTuple> ReverseData(List<TimeSeriesTuple
 
         public Task InitializeAsync() => Task.CompletedTask;
 
+        public void Dispose()
+        {
+            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
+        }
+
         public async Task DisposeAsync()
         {
             var redis = redisFixture.Redis.GetDatabase();

diff --git a/tests/NRedisStack.Tests/Bloom/BloomTests.cs b/tests/NRedisStack.Tests/Bloom/BloomTests.cs
@@ -9,11 +9,6 @@ public class BloomTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "BLOOM_TESTS";
     public BloomTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     [Fact]
     public void TestReserveBasic()
     {

diff --git a/tests/NRedisStack.Tests/CountMinSketch/CmsTests.cs b/tests/NRedisStack.Tests/CountMinSketch/CmsTests.cs
@@ -9,10 +9,6 @@ public class CmsTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "CMS_TESTS";
     public CmsTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
 
     [Fact]
     public void TestInitByDim()

diff --git a/tests/NRedisStack.Tests/CuckooFilter/CuckooTests.cs b/tests/NRedisStack.Tests/CuckooFilter/CuckooTests.cs
@@ -9,11 +9,6 @@ public class CuckooTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "CUCKOO_TESTS";
     public CuckooTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     [Fact]
     public void TestReserveBasic()
     {

diff --git a/tests/NRedisStack.Tests/Examples/ExampleTests.cs b/tests/NRedisStack.Tests/Examples/ExampleTests.cs
@@ -26,11 +26,6 @@ public ExampleTests(RedisFixture redisFixture, ITestOutputHelper testOutputHelpe
         this.testOutputHelper = testOutputHelper;
     }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     [SkipIfRedis(Is.OSSCluster)]
     public void HSETandSearch()
     {

diff --git a/tests/NRedisStack.Tests/Gears/GearsTests.cs b/tests/NRedisStack.Tests/Gears/GearsTests.cs
@@ -8,12 +8,6 @@ public class GearsTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "GEARS_TESTS";
     public GearsTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
-
     [SkipIfRedis(Comparison.LessThan, "7.1.242")]
     public void TestTFunctionLoadDelete()
     {

diff --git a/tests/NRedisStack.Tests/Graph/GraphTests.cs b/tests/NRedisStack.Tests/Graph/GraphTests.cs
@@ -11,11 +11,6 @@ public class GraphTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "GRAPH_TESTS";
     public GraphTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     #region SyncTests
 
     [SkipIfRedis(Comparison.GreaterThanOrEqual, "7.1.242")]

diff --git a/tests/NRedisStack.Tests/PipelineTests.cs b/tests/NRedisStack.Tests/PipelineTests.cs
@@ -11,11 +11,6 @@ public class PipelineTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "PIPELINE_TESTS";
     public PipelineTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     [SkipIfRedis(Is.OSSCluster, Comparison.GreaterThanOrEqual, "7.1.242")]
     public async Task TestModulsPipeline()
     {

diff --git a/tests/NRedisStack.Tests/Tdigest/TdigestTests.cs b/tests/NRedisStack.Tests/Tdigest/TdigestTests.cs
@@ -9,11 +9,6 @@ public class TdigestTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "TDIGEST_TESTS";
     public TdigestTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     private void AssertMergedUnmergedNodes(ITdigestCommands tdigest, string key, int mergedNodes, int unmergedNodes)
     {
         var info = tdigest.Info(key);

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestAdd.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestAdd.cs
@@ -11,11 +11,6 @@ public class TestAdd : AbstractNRedisStackTest, IDisposable
 
         public TestAdd(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public void TestAddNotExistingTimeSeries()
         {

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestAlter.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestAlter.cs
@@ -12,11 +12,6 @@ public class TestAlter : AbstractNRedisStackTest, IDisposable
 
         public TestAlter(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public void TestAlterRetentionTime()
         {

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestCreate.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestCreate.cs
@@ -12,11 +12,6 @@ public class TestCreate : AbstractNRedisStackTest, IDisposable
 
         public TestCreate(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public void TestCreateOK()
         {

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestDecrBy.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestDecrBy.cs
@@ -11,11 +11,6 @@ public class TestDecrBy : AbstractNRedisStackTest, IDisposable
 
         public TestDecrBy(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public void TestDefaultDecrBy()
         {

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestDel.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestDel.cs
@@ -12,11 +12,6 @@ public class TestDel : AbstractNRedisStackTest, IDisposable
 
         public TestDel(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         private List<TimeSeriesTuple> CreateData(ITimeSeriesCommands ts, int timeBucket) //TODO: check this
         {
             var tuples = new List<TimeSeriesTuple>();

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestGet.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestGet.cs
@@ -12,11 +12,6 @@ public class TestGet : AbstractNRedisStackTest, IDisposable
 
         public TestGet(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public void TestGetNotExists()
         {

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestIncrBy.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestIncrBy.cs
@@ -11,11 +11,6 @@ public class TestIncrBy : AbstractNRedisStackTest, IDisposable
 
         public TestIncrBy(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public void TestDefaultIncrBy()
         {

diff --git a/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestRange.cs b/tests/NRedisStack.Tests/TimeSeries/TestAPI/TestRange.cs
@@ -12,11 +12,6 @@ public class TestRange : AbstractNRedisStackTest, IDisposable
 
         public TestRange(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         private List<TimeSeriesTuple> CreateData(ITimeSeriesCommands ts, int timeBucket)
         {
             var tuples = new List<TimeSeriesTuple>();

diff --git a/tests/NRedisStack.Tests/TimeSeries/TimeSeriesTests.cs b/tests/NRedisStack.Tests/TimeSeries/TimeSeriesTests.cs
@@ -10,11 +10,6 @@ public class TimeSeriesTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "TIME_SERIES_TESTS";
     public TimeSeriesTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
-
     // [Fact]
     // public void TestCreateOK()
     // {

diff --git a/tests/NRedisStack.Tests/TopK/TopKTests.cs b/tests/NRedisStack.Tests/TopK/TopKTests.cs
@@ -9,10 +9,6 @@ public class TopKTests : AbstractNRedisStackTest, IDisposable
     private readonly string key = "TOPK_TESTS";
     public TopKTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-    public void Dispose()
-    {
-        redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-    }
 
     [Fact]
     public void CreateTopKFilter()

diff --git a/tests/NRedisStack.Tests/TransactionsTests.cs b/tests/NRedisStack.Tests/TransactionsTests.cs
@@ -11,11 +11,6 @@ public class TransactionTests : AbstractNRedisStackTest, IDisposable
         private readonly string key = "TRX_TESTS";
         public TransactionTests(RedisFixture redisFixture) : base(redisFixture) { }
 
-        public void Dispose()
-        {
-            redisFixture.Redis.GetDatabase().ExecuteBroadcast("FLUSHALL");
-        }
-
         [Fact]
         public async Task TestJsonTransaction()
         {