From f38027398cb9034166545fc5b64ef277e72b9e45 Mon Sep 17 00:00:00 2001
From: Samson Amaugo <sammychinedu2ky@gmail.com>
Date: Wed, 26 Jun 2024 18:02:24 +0100
Subject: [PATCH] ce fini

---
 Client/Program.cs                     |  5 ++---
 Provider/RedisStreamAdapter.cs        |  5 -----
 Provider/RedisStreamBatchContainer.cs |  5 -----
 Provider/RedisStreamFactory.cs        |  3 +--
 Provider/RedisStreamFailureHandler.cs |  7 +------
 Provider/RedisStreamSequenceToken.cs  | 16 +++++-----------
 Server/Program.cs                     |  5 +----
 7 files changed, 10 insertions(+), 36 deletions(-)

diff --git a/Client/Program.cs b/Client/Program.cs
index d45c881..3cef062 100644
--- a/Client/Program.cs
+++ b/Client/Program.cs
@@ -1,5 +1,4 @@
-using Microsoft.CodeAnalysis.Operations;
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using Orleans.Configuration;
@@ -46,7 +45,7 @@ var task = Task.Run(async () =>
     {
         logger.LogInformation("Sending number {Number}", num);
         await stream.OnNextAsync(num++);
-        
+
         if (num == 20)
         {
             break;
diff --git a/Provider/RedisStreamAdapter.cs b/Provider/RedisStreamAdapter.cs
index 29b72db..50575ba 100644
--- a/Provider/RedisStreamAdapter.cs
+++ b/Provider/RedisStreamAdapter.cs
@@ -2,12 +2,7 @@
 using Orleans.Runtime;
 using Orleans.Streams;
 using StackExchange.Redis;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
 using System.Text.Json;
-using System.Threading.Tasks;
 
 namespace Provider
 {
diff --git a/Provider/RedisStreamBatchContainer.cs b/Provider/RedisStreamBatchContainer.cs
index adf7cd6..c799067 100644
--- a/Provider/RedisStreamBatchContainer.cs
+++ b/Provider/RedisStreamBatchContainer.cs
@@ -1,12 +1,7 @@
 using Orleans.Runtime;
 using Orleans.Streams;
 using StackExchange.Redis;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
 using System.Text.Json;
-using System.Threading.Tasks;
 
 namespace Provider
 {
diff --git a/Provider/RedisStreamFactory.cs b/Provider/RedisStreamFactory.cs
index 64ca81d..a25c1ab 100644
--- a/Provider/RedisStreamFactory.cs
+++ b/Provider/RedisStreamFactory.cs
@@ -1,6 +1,5 @@
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
-using Orleans;
 using Orleans.Configuration;
 using Orleans.Providers.Streams.Common;
 using Orleans.Streams;
@@ -56,7 +55,7 @@ namespace Provider
 
         public IQueueAdapterCache GetQueueAdapterCache()
         {
-            return new SimpleQueueAdapterCache(_simpleQueueCacheOptions,_providerName, _loggerFactory);
+            return new SimpleQueueAdapterCache(_simpleQueueCacheOptions, _providerName, _loggerFactory);
         }
 
         public IStreamQueueMapper GetStreamQueueMapper()
diff --git a/Provider/RedisStreamFailureHandler.cs b/Provider/RedisStreamFailureHandler.cs
index 4e6303a..6734c12 100644
--- a/Provider/RedisStreamFailureHandler.cs
+++ b/Provider/RedisStreamFailureHandler.cs
@@ -1,11 +1,6 @@
 using Microsoft.Extensions.Logging;
 using Orleans.Runtime;
 using Orleans.Streams;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace Provider
 {
@@ -19,7 +14,7 @@ namespace Provider
         }
 
         public bool ShouldFaultSubsriptionOnError => true;
-        
+
 
         public Task OnDeliveryFailure(GuidId subscriptionId, string streamProviderName, StreamId streamIdentity, StreamSequenceToken sequenceToken)
         {
diff --git a/Provider/RedisStreamSequenceToken.cs b/Provider/RedisStreamSequenceToken.cs
index 46fca61..53b7190 100644
--- a/Provider/RedisStreamSequenceToken.cs
+++ b/Provider/RedisStreamSequenceToken.cs
@@ -1,11 +1,5 @@
-using Orleans;
-using Orleans.Streams;
+using Orleans.Streams;
 using StackExchange.Redis;
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 
 namespace Provider
 {
@@ -15,7 +9,7 @@ namespace Provider
         [Id(0)]
         public override long SequenceNumber { get; protected set; }
         [Id(1)]
-        public override int EventIndex { get ; protected set ; }
+        public override int EventIndex { get; protected set; }
 
         public RedisStreamSequenceToken(RedisValue id)
         {
@@ -31,10 +25,10 @@ namespace Provider
         }
         public override int CompareTo(StreamSequenceToken other)
         {
-            if(other is null) throw new ArgumentNullException(nameof(other));
-            if(other is RedisStreamSequenceToken token)
+            if (other is null) throw new ArgumentNullException(nameof(other));
+            if (other is RedisStreamSequenceToken token)
             {
-                if(SequenceNumber == token.SequenceNumber)
+                if (SequenceNumber == token.SequenceNumber)
                 {
                     return EventIndex.CompareTo(token.EventIndex);
                 }
diff --git a/Server/Program.cs b/Server/Program.cs
index 04ba6aa..875ded2 100644
--- a/Server/Program.cs
+++ b/Server/Program.cs
@@ -1,12 +1,9 @@
-
-
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
 using Orleans.Configuration;
 using Orleans.Runtime;
 using Orleans.Streams;
-using Provider;
 using StackExchange.Redis;
 
 var builder = new HostBuilder()