dan/Toolkit2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixes

Browse Source
This commit is contained in:
Dan Clark
2024-11-25 10:39:14 +00:00
parent d1ee8add0c
commit f7a96b3784
5 changed files with 41 additions and 64 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Toolkit.Foundation/AsyncHandlerInitialization.cs
+20 -27
View File
@@ -12,28 +12,24 @@ public class AsyncHandlerInitialization<TMessage, TResponse, THandler>(IServiceP
if (!StrongReferenceMessenger.Default.IsRegistered<AsyncResponseEventArgs<TMessage, TResponse>>(provider))
{
StrongReferenceMessenger.Default.Register<IServiceProvider, AsyncResponseEventArgs<TMessage, TResponse>>(provider,
async (provider, args) =>
(provider, args) =>
{
IEnumerable<IAsyncHandler<TMessage, TResponse>> handlers = provider.GetServices<IAsyncHandler<TMessage, TResponse>>();
IEnumerable<IAsyncPipelineBehavior<TMessage, TResponse>> behaviors = provider.GetServices<IAsyncPipelineBehavior<TMessage, TResponse>>();
AsyncHandlerDelegate<TResponse> handlerDelegate = async () =>
foreach (IAsyncHandler<TMessage, TResponse> handler in handlers)
{
TResponse response = default!;
foreach (IAsyncHandler<TMessage, TResponse> handler in handlers)
AsyncHandlerDelegate<TResponse> handlerDelegate = () =>
handler.Handle(args.Message, args.CancellationToken);
foreach (IAsyncPipelineBehavior<TMessage, TResponse>? behavior in behaviors.Reverse())
{
response = await handler.Handle(args.Message, args.CancellationToken);
AsyncHandlerDelegate<TResponse> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
}
return response;
};
foreach (IAsyncPipelineBehavior<TMessage, TResponse> behavior in behaviors.Reverse())
{
AsyncHandlerDelegate<TResponse> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
args.Reply(handlerDelegate());
}
args.Reply(await handlerDelegate());
});
}
}
@@ -48,29 +44,26 @@ public class AsyncHandlerInitialization<TMessage, THandler>(IServiceProvider pro
if (!StrongReferenceMessenger.Default.IsRegistered<AsyncResponseEventArgs<TMessage, Unit>>(provider))
{
StrongReferenceMessenger.Default.Register<IServiceProvider, AsyncResponseEventArgs<TMessage, Unit>>(provider,
async (provider, args) =>
(provider, args) =>
{
IEnumerable<IAsyncHandler<TMessage>> handlers = provider.GetServices<IAsyncHandler<TMessage>>();
IEnumerable<IAsyncPipelineBehavior<TMessage, Unit>> behaviors = provider.GetServices<IAsyncPipelineBehavior<TMessage, Unit>>();
AsyncHandlerDelegate<Unit> handlerDelegate = async () =>
foreach (IAsyncHandler<TMessage> handler in handlers)
{
foreach (IAsyncHandler<TMessage> handler in handlers)
AsyncHandlerDelegate<Unit> handlerDelegate = () =>
handler.Handle(args.Message, args.CancellationToken).ContinueWith(_ => Unit.Value);
foreach (IAsyncPipelineBehavior<TMessage, Unit> behavior in behaviors.Reverse())
{
await handler.Handle(args.Message, args.CancellationToken);
AsyncHandlerDelegate<Unit> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
}
return Unit.Value;
};
foreach (IAsyncPipelineBehavior<TMessage, Unit> behavior in behaviors.Reverse())
{
AsyncHandlerDelegate<Unit> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
handlerDelegate();
args.Reply(Unit.Value);
}
await handlerDelegate();
args.Reply(Unit.Value);
});
}
}
}
}
Toolkit.Foundation/AsyncHandlerKeyedInitialization.cs
+20 -27
View File
@@ -12,28 +12,25 @@ public class AsyncHandlerKeyedInitialization<TMessage, THandler>(string key, ISe
if (!StrongReferenceMessenger.Default.IsRegistered<AsyncResponseEventArgs<TMessage, Unit>, string>(provider, key))
{
StrongReferenceMessenger.Default.Register<IServiceProvider, AsyncResponseEventArgs<TMessage, Unit>, string>(provider, key,
async (provider, args) =>
(provider, args) =>
{
IEnumerable<IAsyncHandler<TMessage>> handlers = provider.GetKeyedServices<IAsyncHandler<TMessage>>(key);
IEnumerable<IAsyncPipelineBehavior<TMessage, Unit>> behaviors = provider.GetServices<IAsyncPipelineBehavior<TMessage, Unit>>();
AsyncHandlerDelegate<Unit> handlerDelegate = async () =>
foreach (IAsyncHandler<TMessage> handler in handlers)
{
foreach (IAsyncHandler<TMessage> handler in handlers)
AsyncHandlerDelegate<Unit> handlerDelegate = () =>
handler.Handle(args.Message, args.CancellationToken).ContinueWith(_ => Unit.Value);
foreach (IAsyncPipelineBehavior<TMessage, Unit> behavior in behaviors.Reverse())
{
await handler.Handle(args.Message, args.CancellationToken);
AsyncHandlerDelegate<Unit> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
}
return Unit.Value;
};
foreach (IAsyncPipelineBehavior<TMessage, Unit> behavior in behaviors.Reverse())
{
AsyncHandlerDelegate<Unit> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
handlerDelegate();
args.Reply(Unit.Value);
}
await handlerDelegate();
args.Reply(Unit.Value);
});
}
}
@@ -48,29 +45,25 @@ public class AsyncHandlerKeyedInitialization<TMessage, TResponse, THandler>(stri
if (!StrongReferenceMessenger.Default.IsRegistered<AsyncResponseEventArgs<TMessage, TResponse>, string>(provider, key))
{
StrongReferenceMessenger.Default.Register<IServiceProvider, AsyncResponseEventArgs<TMessage, TResponse>, string>(provider, key,
async (provider, args) =>
(provider, args) =>
{
IEnumerable<IAsyncHandler<TMessage, TResponse>> handlers = provider.GetKeyedServices<IAsyncHandler<TMessage, TResponse>>(key);
IEnumerable<IAsyncPipelineBehavior<TMessage, TResponse>> behaviors = provider.GetServices<IAsyncPipelineBehavior<TMessage, TResponse>>();
AsyncHandlerDelegate<TResponse> handlerDelegate = async () =>
foreach (IAsyncHandler<TMessage, TResponse> handler in handlers)
{
TResponse response = default!;
foreach (IAsyncHandler<TMessage, TResponse> handler in handlers)
AsyncHandlerDelegate<TResponse> handlerDelegate = () =>
handler.Handle(args.Message, args.CancellationToken);
foreach (IAsyncPipelineBehavior<TMessage, TResponse> behavior in behaviors.Reverse())
{
response = await handler.Handle(args.Message, args.CancellationToken);
AsyncHandlerDelegate<TResponse> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
}
return response;
};
foreach (IAsyncPipelineBehavior<TMessage, TResponse> behavior in behaviors.Reverse())
{
AsyncHandlerDelegate<TResponse> next = handlerDelegate;
handlerDelegate = () => behavior.Handle(args.Message, next);
args.Reply(handlerDelegate());
}
args.Reply(await handlerDelegate());
});
}
}
}
}
Toolkit.Foundation/ConfigurationInitializer.cs
+1 -1
View File
@@ -22,6 +22,6 @@ public class ConfigurationInitializer<TConfiguration>(IConfigurationReader<TConf
}
}
messenger.Send(new ActivatedEventArgs<TConfiguration>(configuration));
messenger.Send(new ActivatedEventArgs<TConfiguration?>(configuration));
}
}