Initialization rework
This commit is contained in:
@@ -6,19 +6,16 @@ namespace Toolkit.Foundation
|
||||
public class AppService : IHostedService
|
||||
{
|
||||
private readonly IMediator mediator;
|
||||
private readonly IInitialization initialization;
|
||||
|
||||
public AppService(IMediator mediator,
|
||||
IInitialization initialization)
|
||||
public AppService(IMediator mediator)
|
||||
{
|
||||
this.mediator = mediator;
|
||||
this.initialization = initialization;
|
||||
}
|
||||
|
||||
public async Task StartAsync(CancellationToken cancellationToken)
|
||||
{
|
||||
await mediator.Send(new Initialize());
|
||||
await initialization.InitializeAsync();
|
||||
await mediator.Send(new Initialization());
|
||||
await mediator.Send(new Initialized());
|
||||
}
|
||||
|
||||
public Task StopAsync(CancellationToken cancellationToken)
|
||||
|
||||
@@ -1,7 +0,0 @@
|
||||
namespace Toolkit.Foundation
|
||||
{
|
||||
public interface IInitialization
|
||||
{
|
||||
Task InitializeAsync();
|
||||
}
|
||||
}
|
||||
@@ -1,23 +1,6 @@
|
||||
namespace Toolkit.Foundation
|
||||
using Mediator;
|
||||
|
||||
namespace Toolkit.Foundation
|
||||
{
|
||||
public class Initialization : IInitialization
|
||||
{
|
||||
private readonly Func<IEnumerable<IInitializer?>> factory;
|
||||
|
||||
public Initialization(Func<IEnumerable<IInitializer?>> factory)
|
||||
{
|
||||
this.factory = factory;
|
||||
}
|
||||
|
||||
public async Task InitializeAsync()
|
||||
{
|
||||
foreach (IInitializer? initializer in factory())
|
||||
{
|
||||
if (initializer is not null)
|
||||
{
|
||||
await initializer.InitializeAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
public record Initialization : IRequest;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,27 @@
|
||||
using Mediator;
|
||||
|
||||
namespace Toolkit.Foundation
|
||||
{
|
||||
public class InitializationHandler : IRequestHandler<Initialization>
|
||||
{
|
||||
private readonly IEnumerable<IInitializer?> initializers;
|
||||
|
||||
public InitializationHandler(IEnumerable<IInitializer?> initializers)
|
||||
{
|
||||
this.initializers = initializers;
|
||||
}
|
||||
|
||||
public async ValueTask<Unit> Handle(Initialization request, CancellationToken cancellationToken)
|
||||
{
|
||||
foreach (IInitializer? initializer in initializers)
|
||||
{
|
||||
if (initializer is not null)
|
||||
{
|
||||
await initializer.InitializeAsync();
|
||||
}
|
||||
}
|
||||
|
||||
return default;
|
||||
}
|
||||
}
|
||||
}
|
||||
+1
-1
@@ -2,5 +2,5 @@
|
||||
|
||||
namespace Toolkit.Foundation
|
||||
{
|
||||
public record class Initialize : IRequest;
|
||||
public record class Initialized : IRequest;
|
||||
}
|
||||
Reference in New Issue
Block a user