From 7c92fc08f5c6b38e93d8f5d227a453710ba115d8 Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Tue, 18 Feb 2025 14:56:02 -0800 Subject: [PATCH] Fix stream perf test `FSharp.Core` must be referenced. --- Directory.Packages.props | 6 +++++- .../Directory.Build.targets | 12 ------------ RabbitMQ.Stream.Client.PerfTest/Program.fs | 6 ++---- .../RabbitMQ.Stream.Client.PerfTest.fsproj | 4 ++++ 4 files changed, 11 insertions(+), 17 deletions(-) delete mode 100644 RabbitMQ.Stream.Client.PerfTest/Directory.Build.targets diff --git a/Directory.Packages.props b/Directory.Packages.props index a7b04f0f..c7cb3d9b 100644 --- a/Directory.Packages.props +++ b/Directory.Packages.props @@ -26,11 +26,15 @@ + + + + - \ No newline at end of file + diff --git a/RabbitMQ.Stream.Client.PerfTest/Directory.Build.targets b/RabbitMQ.Stream.Client.PerfTest/Directory.Build.targets deleted file mode 100644 index c53f5eab..00000000 --- a/RabbitMQ.Stream.Client.PerfTest/Directory.Build.targets +++ /dev/null @@ -1,12 +0,0 @@ - - - - - - diff --git a/RabbitMQ.Stream.Client.PerfTest/Program.fs b/RabbitMQ.Stream.Client.PerfTest/Program.fs index f749d90a..8f83e61c 100644 --- a/RabbitMQ.Stream.Client.PerfTest/Program.fs +++ b/RabbitMQ.Stream.Client.PerfTest/Program.fs @@ -24,12 +24,10 @@ let main argv = Reference = Guid.NewGuid().ToString(), MessageHandler = fun c ctx m -> - consumed <- consumed + 1 Task.CompletedTask ) let t = task { - let config = StreamSystemConfig(UserName = "guest", - Password = "guest") + let config = StreamSystemConfig(UserName = "guest", Password = "guest") let! system = StreamSystem.Create config let! stream = system.CreateStream(StreamSpec(streamName)) printfn $"Stream: {streamName}" @@ -67,4 +65,4 @@ let main argv = //t.Wait() Console.ReadKey() |> ignore run <- false - 0 \ No newline at end of file + 0 diff --git a/RabbitMQ.Stream.Client.PerfTest/RabbitMQ.Stream.Client.PerfTest.fsproj b/RabbitMQ.Stream.Client.PerfTest/RabbitMQ.Stream.Client.PerfTest.fsproj index 94f0fdcb..6425f8a3 100644 --- a/RabbitMQ.Stream.Client.PerfTest/RabbitMQ.Stream.Client.PerfTest.fsproj +++ b/RabbitMQ.Stream.Client.PerfTest/RabbitMQ.Stream.Client.PerfTest.fsproj @@ -16,6 +16,10 @@ + + + +