Skip to content

Commit

Permalink
Tidy
Browse files Browse the repository at this point in the history
  • Loading branch information
bartelink committed Dec 24, 2021
1 parent 10a610e commit c54d505
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions propulsion-reactor/Program.fs
Original file line number Diff line number Diff line change
Expand Up @@ -641,14 +641,13 @@ let build (args : Args.Arguments) =
[ Async.AwaitKeyboardInterruptAsTaskCancelledException(); source.AwaitWithStopOnCancellation(); sink.AwaitWithStopOnCancellation() ]
#endif // !kafkaEventSpans

let run args = async {
let run args =
#if (!kafkaEventSpans)
return! Async.Parallel (build args) |> Async.Ignore<unit array>
Async.Parallel (build args) |> Async.Ignore<unit array>
#else
let sink = build args
return! sink.AwaitWithStopOnCancellation()
sink.AwaitWithStopOnCancellation()
#endif
}

[<EntryPoint>]
let main argv =
Expand Down

0 comments on commit c54d505

Please sign in to comment.