Rename RegisterFlows to RegisterFlow in IoC binding setup (#9)

stidsborg · web-flow · commit 2a3024d65fc6 · 2026-05-03T10:12:42.000+02:00
diff --git a/Cleipnir.Tests.AspNet/IntegrationTest.cs b/Cleipnir.Tests.AspNet/IntegrationTest.cs
@@ -79,7 +79,7 @@ IFunctionStore functionStore
         bindings(builder.Services);
         builder.Services.AddFlows(c => c
             .UseStore(functionStore)
-            .RegisterFlows<TestFlow, string, string>()
+            .RegisterFlow<TestFlow, string, string>()
         );
 
         var app = builder.Build();
diff --git a/Cleipnir.Tests/Flows/OptionsTests.cs b/Cleipnir.Tests/Flows/OptionsTests.cs
@@ -21,7 +21,7 @@ public async Task SimpleFlowCompletesSuccessfully()
                 messagesDefaultMaxWaitForCompletion: TimeSpan.FromDays(1),
                 watchdogCheckFrequency: TimeSpan.FromMilliseconds(100)
             ))
-            .RegisterFlows<OptionsTestWithDefaultProvidedOptionsFlow>()
+            .RegisterFlow<OptionsTestWithDefaultProvidedOptionsFlow>()
         );
         serviceCollection.AddScoped<OptionsTestWithOverriddenOptionsFlow>();
         serviceCollection.AddTransient(sp => new Flows<OptionsTestWithOverriddenOptionsFlow>(
diff --git a/Cleipnir/AspNet/FlowsModule.cs b/Cleipnir/AspNet/FlowsModule.cs
@@ -61,7 +61,7 @@ public FlowsConfigurator WithOptions(Func<IServiceProvider, Options> optionsFunc
         return this;
     }
 
-    public FlowsConfigurator RegisterFlows<TFlow>() where TFlow : Flow
+    public FlowsConfigurator RegisterFlow<TFlow>() where TFlow : Flow
     {
         var added = FlowsTypes.Add(typeof(Flows<TFlow>));
         if (!added) return this;
@@ -76,7 +76,7 @@ public FlowsConfigurator RegisterFlows<TFlow>() where TFlow : Flow
 
         return this;
     }
-    public FlowsConfigurator RegisterFlows<TFlow, TParam>() where TFlow : Flow<TParam> where TParam : notnull
+    public FlowsConfigurator RegisterFlow<TFlow, TParam>() where TFlow : Flow<TParam> where TParam : notnull
     {
         var added = FlowsTypes.Add(typeof(Flows<TFlow, TParam>));
         if (!added) return this;
@@ -91,7 +91,7 @@ public FlowsConfigurator RegisterFlows<TFlow, TParam>() where TFlow : Flow<TPara
 
         return this;
     }
-    public FlowsConfigurator RegisterFlows<TFlow, TParam, TResult>() where TFlow : Flow<TParam, TResult> where TParam : notnull
+    public FlowsConfigurator RegisterFlow<TFlow, TParam, TResult>() where TFlow : Flow<TParam, TResult> where TParam : notnull
     {
         var added = FlowsTypes.Add(typeof(Flows<TFlow, TParam, TResult>));
         if (!added) return this;
diff --git a/README.md b/README.md
@@ -125,7 +125,7 @@ Secondly, add the following to the setup in `Program.cs` ([source code](https://
 ```csharp
 builder.Services.AddFlows(c => c
   .UsePostgresStore(connectionString)  
-  .RegisterFlows<OrderFlow, Order>()
+  .RegisterFlow<OrderFlow, Order>()
 );
 ```
 
diff --git a/Samples/Cleipnir.Sample.AspNet/Program.cs b/Samples/Cleipnir.Sample.AspNet/Program.cs
@@ -28,7 +28,7 @@ private static async Task Main(string[] args)
         builder.Services.AddFlows(c => c
             .UsePostgresStore(connectionString)
             .WithOptions(new Options(leaseLength: TimeSpan.FromSeconds(5)))
-            .RegisterFlows<OrderFlow, Order>()
+            .RegisterFlow<OrderFlow, Order>()
         );
         
         // Add services to the container.
diff --git a/Samples/Cleipnir.Sample.Presentation.AspNet/Program.cs b/Samples/Cleipnir.Sample.Presentation.AspNet/Program.cs
@@ -33,11 +33,11 @@ private static async Task Main(string[] args)
         builder.Services.AddFlows(c => c
             .UsePostgresStore(connectionString)
             .WithOptions(new Options(leaseLength: TimeSpan.FromSeconds(5), messagesDefaultMaxWaitForCompletion: TimeSpan.MaxValue))
-            .RegisterFlows<OrderFlow, Order>()
-            .RegisterFlows<BatchOrderFlow, List<Order>>()
-            .RegisterFlows<SingleOrderFlow, Order, TransactionIdAndTrackAndTrace>()
-            .RegisterFlows<InvoiceFlow, CustomerNumber>()
-            .RegisterFlows<MessageDrivenOrderFlow, Order>()
+            .RegisterFlow<OrderFlow, Order>()
+            .RegisterFlow<BatchOrderFlow, List<Order>>()
+            .RegisterFlow<SingleOrderFlow, Order, TransactionIdAndTrackAndTrace>()
+            .RegisterFlow<InvoiceFlow, CustomerNumber>()
+            .RegisterFlow<MessageDrivenOrderFlow, Order>()
         );
 
         builder.Services.AddInMemoryBus();
diff --git a/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Distributed/Example.cs b/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Distributed/Example.cs
@@ -22,7 +22,7 @@ public static async Task Perform()
                     c => c
                         .UseStore(store)
                         .WithOptions(new Options(unhandledExceptionHandler: Console.WriteLine))
-                        .RegisterFlows<NewsletterParentFlow, MailAndRecipients>()
+                        .RegisterFlow<NewsletterParentFlow, MailAndRecipients>()
                 );
                 serviceCollection.AddScoped(sp => new NewsletterChildFlow(sp.GetRequiredService<Flows<NewsletterParentFlow, MailAndRecipients>>(), child));
                 serviceCollection.AddTransient(sp => new Flows<NewsletterChildFlow, NewsletterChildWork>(
diff --git a/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Example.cs b/Samples/Cleipnir.Sample.Presentation/C_NewsletterSender/Example.cs
@@ -20,7 +20,7 @@ public static async Task Perform()
             c => c
                 .UseStore(store)
                 .WithOptions(new Options(unhandledExceptionHandler: Console.WriteLine))
-                .RegisterFlows<NewsletterFlow, MailAndRecipients>()
+                .RegisterFlow<NewsletterFlow, MailAndRecipients>()
         );
 
         var sp = serviceCollection.BuildServiceProvider();
diff --git a/ServiceBuses/MassTransit/Cleipnir.MassTransit.Console/Program.cs b/ServiceBuses/MassTransit/Cleipnir.MassTransit.Console/Program.cs
@@ -36,7 +36,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
             {
                 services.AddFlows(c => c
                     .UseInMemoryStore()
-                    .RegisterFlows<SimpleFlow>()
+                    .RegisterFlow<SimpleFlow>()
                 );
                 
                 services.AddMassTransit(x =>
diff --git a/ServiceBuses/MassTransit/Cleipnir.MassTransit.RabbitMq.Console/Program.cs b/ServiceBuses/MassTransit/Cleipnir.MassTransit.RabbitMq.Console/Program.cs
@@ -45,7 +45,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
                 
                 services.AddFlows(c => c
                     .UseInMemoryStore()
-                    .RegisterFlows<OrderFlow, Order>()
+                    .RegisterFlow<OrderFlow, Order>()
                 );
                 
                 services.AddMassTransit(x =>
diff --git a/ServiceBuses/NServiceBus/Cleipnir.NServiceBus.Console/Program.cs b/ServiceBuses/NServiceBus/Cleipnir.NServiceBus.Console/Program.cs
@@ -36,7 +36,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
             {
                 services.AddFlows(c => c
                         .UseInMemoryStore()
-                        .RegisterFlows<SimpleFlow>()
+                        .RegisterFlow<SimpleFlow>()
                 );
 
             }).UseNServiceBus(_ =>
diff --git a/ServiceBuses/Rebus/Cleipnir.Rebus.Console/Program.cs b/ServiceBuses/Rebus/Cleipnir.Rebus.Console/Program.cs
@@ -37,7 +37,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
             {
                 services.AddFlows(c => c
                     .UseInMemoryStore()
-                    .RegisterFlows<SimpleFlow>()
+                    .RegisterFlow<SimpleFlow>()
                 );
 
                 services.AutoRegisterHandlersFromAssembly(typeof(Program).Assembly);
diff --git a/ServiceBuses/Wolverine/Cleipnir.Wolverine.Console/Program.cs b/ServiceBuses/Wolverine/Cleipnir.Wolverine.Console/Program.cs
@@ -37,7 +37,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>
             {
                 services.AddFlows(c => c
                     .UseInMemoryStore()
-                    .RegisterFlows<SimpleFlow>()
+                    .RegisterFlow<SimpleFlow>()
                 );
             })
             .UseWolverine();

Original file line number	Diff line number	Diff line change
`@@ -61,7 +61,7 @@ public FlowsConfigurator WithOptions(Func<IServiceProvider, Options> optionsFunc`
`61`	`61`	`return this;`
`62`	`62`	`}`
`63`	`63`
`64`		`- public FlowsConfigurator RegisterFlows<TFlow>() where TFlow : Flow`
	`64`	`+ public FlowsConfigurator RegisterFlow<TFlow>() where TFlow : Flow`
`65`	`65`	`{`
`66`	`66`	`var added = FlowsTypes.Add(typeof(Flows<TFlow>));`
`67`	`67`	`if (!added) return this;`
`@@ -76,7 +76,7 @@ public FlowsConfigurator RegisterFlows<TFlow>() where TFlow : Flow`
`76`	`76`
`77`	`77`	`return this;`
`78`	`78`	`}`
`79`		`- public FlowsConfigurator RegisterFlows<TFlow, TParam>() where TFlow : Flow<TParam> where TParam : notnull`
	`79`	`+ public FlowsConfigurator RegisterFlow<TFlow, TParam>() where TFlow : Flow<TParam> where TParam : notnull`
`80`	`80`	`{`
`81`	`81`	`var added = FlowsTypes.Add(typeof(Flows<TFlow, TParam>));`
`82`	`82`	`if (!added) return this;`
`@@ -91,7 +91,7 @@ public FlowsConfigurator RegisterFlows<TFlow, TParam>() where TFlow : Flow<TPara`
`91`	`91`
`92`	`92`	`return this;`
`93`	`93`	`}`
`94`		`- public FlowsConfigurator RegisterFlows<TFlow, TParam, TResult>() where TFlow : Flow<TParam, TResult> where TParam : notnull`
	`94`	`+ public FlowsConfigurator RegisterFlow<TFlow, TParam, TResult>() where TFlow : Flow<TParam, TResult> where TParam : notnull`
`95`	`95`	`{`
`96`	`96`	`var added = FlowsTypes.Add(typeof(Flows<TFlow, TParam, TResult>));`
`97`	`97`	`if (!added) return this;`
Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ private static IHostBuilder CreateHostBuilder(string[] args) =>`
`36`	`36`	`{`
`37`	`37`	`services.AddFlows(c => c`
`38`	`38`	`.UseInMemoryStore()`
`39`		`- .RegisterFlows<SimpleFlow>()`
	`39`	`+ .RegisterFlow<SimpleFlow>()`
`40`	`40`	`);`
`41`	`41`
`42`	`42`	`services.AddMassTransit(x =>`