Merge pull request #400 from rabbitmq/lukebakken/fix-perf-test

Fix stream perf test

Author: lukebakken

Directory.Packages.props

@@ -26,11 +26,15 @@
     <PackageVersion Include="System.IO.Hashing" Version="8.0.0" />
     <PackageVersion Include="System.IO.Pipelines" Version="8.0.0" />
     <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="8.0.0" />
+    <!-- RabbitMQ.Stream.Client.PerfTest -->
+    <PackageVersion Include="FSharp.Core" Version="8.0.403" />
   </ItemGroup>
   <ItemGroup Label="net9.0 specific" Condition="'$(TargetFramework)' == 'net9.0'">
     <!-- RabbitMQ.Stream.Client -->
     <PackageVersion Include="System.IO.Hashing" Version="9.0.0" />
     <PackageVersion Include="System.IO.Pipelines" Version="9.0.0" />
     <PackageVersion Include="Microsoft.Extensions.Logging.Abstractions" Version="9.0.0" />
+    <!-- RabbitMQ.Stream.Client.PerfTest -->
+    <PackageVersion Include="FSharp.Core" Version="9.0.201" />
   </ItemGroup>
-</Project>
+</Project>

RabbitMQ.Stream.Client.PerfTest/Directory.Build.targets

@@ -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
+    0

RabbitMQ.Stream.Client.PerfTest/Program.fs

@@ -16,6 +16,10 @@
     <Content Include="README.md" />
   </ItemGroup>
 
+  <ItemGroup>
+    <PackageReference Include="FSharp.Core" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\RabbitMQ.Stream.Client\RabbitMQ.Stream.Client.csproj" />
   </ItemGroup>