n-j-m · January 12, 2025 21:04 · Jan 12, 2025
diff --git a/Entity1.cs b/Entity1.cs
@@ -0,0 +1,9 @@
+using MediatR;
+using TypeConst.Cli.Interfaces;
+
+namespace TypeConst.Cli.Models;
+
+public class Entity1 : IName, IRequest
+{
+    public string Name { get; set; } = default!;
+}
diff --git a/Entity1Handler.cs b/Entity1Handler.cs
@@ -0,0 +1,13 @@
+using MediatR;
+using TypeConst.Cli.Interfaces;
+using TypeConst.Cli.Models;
+
+namespace TypeConst.Cli.Handlers;
+
+public class Entity1Handler(IServiceWorker<Entity1> worker) : IRequestHandler<Entity1>
+{
+    public async Task Handle(Entity1 request, CancellationToken cancellationToken)
+    {
+        await worker.DoWorkAsync(request, cancellationToken);
+    }
+}
diff --git a/Entity1ServiceWorker.cs b/Entity1ServiceWorker.cs
@@ -0,0 +1,13 @@
+using TypeConst.Cli.Interfaces;
+using TypeConst.Cli.Models;
+
+namespace TypeConst.Cli.Services;
+
+public class Entity1ServiceWorker : IServiceWorker<Entity1>
+{
+    public async Task DoWorkAsync(Entity1 entity, CancellationToken cancellationToken = default)
+    {
+        Console.WriteLine("Entity1: {0}", entity.Name);
+        await Task.Delay(1000, cancellationToken);
+    }
+}
diff --git a/Entity2.cs b/Entity2.cs
@@ -0,0 +1,9 @@
+using MediatR;
+using TypeConst.Cli.Interfaces;
+
+namespace TypeConst.Cli.Models;
+
+public class Entity2 : IName, IRequest
+{
+    public string Name { get; set; } = default!;
+}
diff --git a/Entity2Handler.cs b/Entity2Handler.cs
@@ -0,0 +1,13 @@
+using MediatR;
+using TypeConst.Cli.Interfaces;
+using TypeConst.Cli.Models;
+
+namespace TypeConst.Cli.Handlers;
+
+public class Entity2Handler(IServiceWorker<Entity2> worker) : IRequestHandler<Entity2>
+{
+    public async Task Handle(Entity2 request, CancellationToken cancellationToken)
+    {
+        await worker.DoWorkAsync(request, cancellationToken);
+    }
+}
diff --git a/Entity2ServiceWorker.cs b/Entity2ServiceWorker.cs
@@ -0,0 +1,13 @@
+using TypeConst.Cli.Interfaces;
+using TypeConst.Cli.Models;
+
+namespace TypeConst.Cli.Services;
+
+public class Entity2ServiceWorker : IServiceWorker<Entity2>
+{
+    public async Task DoWorkAsync(Entity2 entity, CancellationToken cancellationToken = default)
+    {
+        Console.WriteLine("Entity2: {0}", entity.Name);
+        await Task.Delay(2000, cancellationToken);
+    }
+}
diff --git a/IName.cs b/IName.cs
@@ -0,0 +1,6 @@
+namespace TypeConst.Cli.Interfaces;
+
+public interface IName
+{
+    string Name { get; set; }
+}
diff --git a/IServiceWorker.cs b/IServiceWorker.cs
@@ -0,0 +1,6 @@
+namespace TypeConst.Cli.Interfaces;
+
+public interface IServiceWorker<TEntity> where TEntity : IName
+{
+    Task DoWorkAsync(TEntity entity, CancellationToken cancellationToken = default);
+}
diff --git a/Program.cs b/Program.cs
@@ -0,0 +1,29 @@
+// See https://aka.ms/new-console-template for more information
+using MediatR;
+using Microsoft.Extensions.DependencyInjection;
+using TypeConst.Cli.Interfaces;
+using TypeConst.Cli.Models;
+using TypeConst.Cli.Services;
+
+Console.WriteLine("Hello, World!");
+
+var services = new ServiceCollection()
+    .AddSingleton<IServiceWorker<Entity1>>(_ => new Entity1ServiceWorker())
+    .AddSingleton<IServiceWorker<Entity2>>(_ => new Entity2ServiceWorker());
+
+services.AddMediatR(c => c.RegisterServicesFromAssembly(typeof(Program).Assembly));
+
+
+using var provider = services.BuildServiceProvider();
+
+List<IName> names = [
+    new Entity1 { Name = "Entity 1" },
+    new Entity2 { Name = "Entity 2" },
+];
+
+var mediator = provider.GetRequiredService<IMediator>();
+
+foreach (var name in names)
+{
+    await mediator.Send(name);
+}
No results found