diff --git a/Tapeti.Flow/Default/FlowMessageMiddleware.cs b/Tapeti.Flow/Default/FlowMessageMiddleware.cs index 394ae0b..0dbd1c7 100644 --- a/Tapeti.Flow/Default/FlowMessageMiddleware.cs +++ b/Tapeti.Flow/Default/FlowMessageMiddleware.cs @@ -25,6 +25,9 @@ namespace Tapeti.Flow.Default await CallConvergeMethod(context, flowContext.ContinuationMetadata.ConvergeMethodName, flowContext.ContinuationMetadata.ConvergeMethodSync); + else if (flowContext.FlowState.Continuations.Count > 0) + // This is a parallel flow waiting for other continuations, always store the state + await flowContext.Store(); } else await next();