diff --git a/Tapeti.Flow/Default/FlowProvider.cs b/Tapeti.Flow/Default/FlowProvider.cs index 7115ae9..5a6a49a 100644 --- a/Tapeti.Flow/Default/FlowProvider.cs +++ b/Tapeti.Flow/Default/FlowProvider.cs @@ -56,11 +56,10 @@ namespace Tapeti.Flow.Default private async Task SendRequest(FlowContext context, object message, ResponseHandlerInfo responseHandlerInfo, string convergeMethodName = null, bool convergeMethodTaskSync = false) { - Debug.Assert(context.FlowState != null, "context.FlowState != null"); - if (context.FlowState == null) { await CreateNewFlowState(context); + Debug.Assert(context.FlowState != null, "context.FlowState != null"); } var continuationID = Guid.NewGuid();