diff --git a/src/kafunk/AssemblyInfo.fs b/src/kafunk/AssemblyInfo.fs index 6459ddd..521cfe4 100644 --- a/src/kafunk/AssemblyInfo.fs +++ b/src/kafunk/AssemblyInfo.fs @@ -4,10 +4,10 @@ open System.Reflection [<assembly: AssemblyTitleAttribute("kafunk")>] [<assembly: AssemblyProductAttribute("kafunk")>] [<assembly: AssemblyDescriptionAttribute("F# client for Kafka")>] -[<assembly: AssemblyVersionAttribute("0.0.27")>] -[<assembly: AssemblyFileVersionAttribute("0.0.27")>] +[<assembly: AssemblyVersionAttribute("0.0.28")>] +[<assembly: AssemblyFileVersionAttribute("0.0.28")>] do () module internal AssemblyVersionInformation = - let [<Literal>] Version = "0.0.27" - let [<Literal>] InformationalVersion = "0.0.27" + let [<Literal>] Version = "0.0.28" + let [<Literal>] InformationalVersion = "0.0.28" diff --git a/tests/kafunk.Tests/FaultsTests.fs b/tests/kafunk.Tests/FaultsTests.fs index 20098b1..4d512fe 100644 --- a/tests/kafunk.Tests/FaultsTests.fs +++ b/tests/kafunk.Tests/FaultsTests.fs @@ -59,7 +59,7 @@ let ``Faults.AsyncFunc.retryResultList should retry with reevaluation`` () = for attempts in [1..5] do - let mutable i = 0 + let mutable i = 1 let sleepEcho () = if Interlocked.Increment &i > attempts then @@ -103,10 +103,10 @@ let ``Faults.AsyncFunc.retryResultList should retry timeout with backoff and suc let policy = RetryPolicy.constantMs 10 |> RetryPolicy.maxAttempts attempts - let attempts = if fail then attempts + 2 else attempts + let attempts = if fail then attempts + 1 else attempts let sleepEcho = - let mutable i = 0 + let mutable i = 1 fun () -> async { if Interlocked.Increment &i > attempts then return () @@ -121,7 +121,7 @@ let ``Faults.AsyncFunc.retryResultList should retry timeout with backoff and suc |> Faults.AsyncFunc.retryResultList policy let expected = - if fail then Failure (List.init attempts ignore) + if fail then Failure (List.init (attempts - 1) ignore) else Success () let actual = sleepEcho () |> Async.RunSynchronously