Target Equinox 4.0.0-rc.12.12

jet · Aug 22, 2023 · d4a079a · d4a079a
1 parent 8eef521
commit d4a079a
Show file tree

Hide file tree

Showing 7 changed files with 9 additions and 9 deletions.
diff --git a/src/Propulsion.CosmosStore/Propulsion.CosmosStore.fsproj b/src/Propulsion.CosmosStore/Propulsion.CosmosStore.fsproj
@@ -17,7 +17,7 @@
   <ItemGroup>
     <PackageReference Include="MinVer" Version="4.2.0" PrivateAssets="All" />
 
-    <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.12.15" />
+    <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.12.21" />
     <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.10.1" />
   </ItemGroup>
 

diff --git a/src/Propulsion.CosmosStore/ReaderCheckpoint.fs b/src/Propulsion.CosmosStore/ReaderCheckpoint.fs
@@ -122,7 +122,7 @@ let decideUpdate at pos = function
 #if COSMOSV3
 module Equinox = module LoadOption = let AnyCachedValue = ()
 type Equinox.Decider<'e, 's> with
-    member x.TransactAsync(decide, load : unit): Async<'r> =
+    member x.Transact(decide, load : unit): Async<'r> =
         x.TransactAsync(fun s -> async { let! r, es = decide s in return r, Array.toList es })
     member x.Transact(decide, load : unit): Async<'r> =
         x.Transact(decide >> function r, es -> r, Array.toList es)
@@ -139,7 +139,7 @@ type Service internal (resolve: SourceId * TrancheId * string -> Equinox.Decider
         member _.Start(source, tranche, establishOrigin, ct) : Task<Position> =
             let decider = resolve (source, tranche, consumerGroupName)
             let establishOrigin = match establishOrigin with None -> async { return Position.initial } | Some f -> Async.call f.Invoke
-            decider.TransactAsync(decideStart establishOrigin DateTimeOffset.UtcNow defaultCheckpointFrequency, load = Equinox.LoadOption.AnyCachedValue)
+            decider.Transact(decideStart establishOrigin DateTimeOffset.UtcNow defaultCheckpointFrequency, load = Equinox.LoadOption.AnyCachedValue)
             |> Async.executeAsTask ct
 
         /// Ingest a position update

diff --git a/src/Propulsion.DynamoStore/Propulsion.DynamoStore.fsproj b/src/Propulsion.DynamoStore/Propulsion.DynamoStore.fsproj
@@ -23,7 +23,7 @@
     <ItemGroup>
       <PackageReference Include="MinVer" Version="4.2.0" PrivateAssets="All" />
 
-      <PackageReference Include="Equinox.DynamoStore" Version="4.0.0-rc.12.15" />
+      <PackageReference Include="Equinox.DynamoStore" Version="4.0.0-rc.12.21" />
       <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.10.1" />
     </ItemGroup>
 

diff --git a/src/Propulsion.EventStore/Propulsion.EventStore.fsproj b/src/Propulsion.EventStore/Propulsion.EventStore.fsproj
@@ -16,7 +16,7 @@
   <ItemGroup>
     <PackageReference Include="MinVer" Version="4.2.0" PrivateAssets="All" />
 
-    <PackageReference Include="Equinox.EventStore" Version="4.0.0-rc.12.15" />
+    <PackageReference Include="Equinox.EventStore" Version="4.0.0-rc.12.21" />
     <PackageReference Include="FsCodec.Box" Version="3.0.0-rc.10.1" />
   </ItemGroup>
 

diff --git a/src/Propulsion.EventStoreDb/Propulsion.EventStoreDb.fsproj b/src/Propulsion.EventStoreDb/Propulsion.EventStoreDb.fsproj
@@ -15,7 +15,7 @@
   <ItemGroup>
     <PackageReference Include="MinVer" Version="4.2.0" PrivateAssets="All" />
 
-    <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.12.15" />
+    <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.12.21" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/src/Propulsion.MemoryStore/Propulsion.MemoryStore.fsproj b/src/Propulsion.MemoryStore/Propulsion.MemoryStore.fsproj
@@ -19,7 +19,7 @@
     <PackageReference Include="MinVer" Version="4.2.0" PrivateAssets="All" />
 
     <PackageReference Include="FsCodec.Box" Version="3.0.0-rc.10.1" />
-    <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.12.15" />
+    <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.12.21" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/src/Propulsion/Internal.fs b/src/Propulsion/Internal.fs
@@ -75,10 +75,10 @@ module Channel =
     let unboundedSw<'t> = Channel.CreateUnbounded<'t>(UnboundedChannelOptions(SingleWriter = true))
     let unboundedSwSr<'t> = Channel.CreateUnbounded<'t>(UnboundedChannelOptions(SingleWriter = true, SingleReader = true))
     let boundedSw<'t> c = Channel.CreateBounded<'t>(BoundedChannelOptions(c, SingleWriter = true))
-    let waitToWrite (w : ChannelWriter<_>) ct = w.WaitToWriteAsync(ct).AsTask() :> Task
+    let waitToWrite (w : ChannelWriter<_>) ct = let vt = w.WaitToWriteAsync(ct) in vt.AsTask() :> Task
     let tryWrite (w : ChannelWriter<_>) = w.TryWrite
     let write (w : ChannelWriter<_>) = w.TryWrite >> ignore
-    let inline awaitRead (r : ChannelReader<_>) ct = r.WaitToReadAsync(ct).AsTask()
+    let inline awaitRead (r : ChannelReader<_>) ct = let vt = r.WaitToReadAsync(ct) in vt.AsTask()
     let inline tryRead (r : ChannelReader<_>) () =
         let mutable msg = Unchecked.defaultof<_>
         if r.TryRead(&msg) then ValueSome msg else ValueNone