rename extension method

lsfera · Jul 15, 2024 · ef9ac95 · ef9ac95
1 parent c097047
commit ef9ac95
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/src/Blumchen.DependencyInjection/Workers/Worker.cs b/src/Blumchen.DependencyInjection/Workers/Worker.cs
@@ -49,7 +49,7 @@ await pipeline.ExecuteAsync(async token =>
                         .ConnectionString(connectionString)
                         .WithTable(tableDescriptorBuilder)
                         .WithErrorProcessor(errorProcessor)
-                        .Handles<T, IHandler<T>>(handler)
+                        .Consumes<T, IHandler<T>>(handler)
                         .NamingPolicy(namingPolicy)
                         .JsonContext(jsonSerializerContext)
                         .WithPublicationOptions(publicationSetupOptions)

diff --git a/src/Blumchen/Subscriptions/SubscriptionOptionsBuilder.cs b/src/Blumchen/Subscriptions/SubscriptionOptionsBuilder.cs
@@ -83,7 +83,7 @@ public SubscriptionOptionsBuilder WithReplicationOptions(ReplicationSlotManageme
     }
 
     [UsedImplicitly]
-    public SubscriptionOptionsBuilder Handles<T, TU>(TU handler) where T : class
+    public SubscriptionOptionsBuilder Consumes<T, TU>(TU handler) where T : class
         where TU : class, IHandler<T>
     {
         _registry.TryAdd(typeof(T), handler);

diff --git a/src/Subscriber/Program.cs b/src/Subscriber/Program.cs
@@ -34,8 +34,8 @@
             )
             .NamingPolicy(new AttributeNamingPolicy())
             .JsonContext(SourceGenerationContext.Default)
-            .Handles<UserCreatedContract, Consumer>(consumer)
-            .Handles<UserDeletedContract, Consumer>(consumer), ct:ct
+            .Consumes<UserCreatedContract, Consumer>(consumer)
+            .Consumes<UserDeletedContract, Consumer>(consumer), ct:ct
     ).GetAsyncEnumerator(ct);
     await using var cursor1 = cursor.ConfigureAwait(false);
     while (await cursor.MoveNextAsync().ConfigureAwait(false) && !ct.IsCancellationRequested);

diff --git a/src/Tests/DatabaseFixture.cs b/src/Tests/DatabaseFixture.cs
@@ -85,7 +85,7 @@ protected static async Task InsertPoisoningMessage(string connectionString, stri
             .ConnectionString(connectionString)
             .JsonContext(info)
             .NamingPolicy(namingPolicy)
-            .Handles<T, TestHandler<T>>(consumer)
+            .Consumes<T, TestHandler<T>>(consumer)
             .WithTable(o => o.Name(eventsTable))
             .WithPublicationOptions(
                 new PublicationManagement.PublicationSetupOptions(PublicationName: publicationName ?? Randomise("events_pub"))