1
0
mirror of synced 2024-11-14 06:29:17 +00:00

Merge branch 'release/2.9.1' into develop

This commit is contained in:
Mark van Renswoude 2023-04-06 07:51:32 +02:00
commit 69e26b2ae1

View File

@ -407,14 +407,16 @@ namespace Tapeti.Flow.Default
if (convergeMethod.Method.DeclaringType != context.HandlerContext.Controller?.GetType())
throw new YieldPointException("Converge method must be in the same controller class");
await Task.WhenAll(requests.Select(requestInfo =>
flowProvider.SendRequest(
context,
foreach (var requestInfo in requests)
{
await flowProvider.SendRequest(
context,
requestInfo.Message,
requestInfo.ResponseHandlerInfo,
convergeMethod.Method.Name,
convergeMethodSync,
false)));
false);
}
await context.Store(requests.Any(i => i.ResponseHandlerInfo.IsDurableQueue));
});