From caf11f8a24a34d2cb811a8e813e357a7edd6d9c8 Mon Sep 17 00:00:00 2001 From: Ruben Bartelink Date: Mon, 16 Dec 2024 21:55:11 +0000 Subject: [PATCH] SDK 9 tweaks --- src/Equinox.CosmosStore/CosmosStore.fs | 2 +- src/Equinox.EventStoreDb/EventStoreDb.fs | 2 +- tests/Equinox.EventStoreDb.Integration/StoreIntegration.fs | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/Equinox.CosmosStore/CosmosStore.fs b/src/Equinox.CosmosStore/CosmosStore.fs index 6d5db0898..9bc5915b3 100644 --- a/src/Equinox.CosmosStore/CosmosStore.fs +++ b/src/Equinox.CosmosStore/CosmosStore.fs @@ -1484,7 +1484,7 @@ type EventsContext member x.Read(streamName, [] ?ct, [] ?position, [] ?maxCount, [] ?direction): Task[]> = x.GetInternal((streamName, position), ?ct = ct, ?maxCount = maxCount, ?direction = direction) |> yieldPositionAndData - [] + [] member x.Sync(streamName, position, events: IEventData<_>[], ct): Task> = x.Sync(streamName, position, events, Array.empty, ct) diff --git a/src/Equinox.EventStoreDb/EventStoreDb.fs b/src/Equinox.EventStoreDb/EventStoreDb.fs index e4220050d..c15f392f9 100644 --- a/src/Equinox.EventStoreDb/EventStoreDb.fs +++ b/src/Equinox.EventStoreDb/EventStoreDb.fs @@ -455,7 +455,7 @@ type EventStoreConnector member _.Connect ( // Name should be sufficient to uniquely identify this connection within a single app instance's logs - name, discovery: Discovery, ?clusterNodePreference): EventStoreClient = + name: string, discovery: Discovery, ?clusterNodePreference): EventStoreClient = if name = null then nullArg "name" let name = String.concat ";" <| seq { name diff --git a/tests/Equinox.EventStoreDb.Integration/StoreIntegration.fs b/tests/Equinox.EventStoreDb.Integration/StoreIntegration.fs index 03578681d..4425c4ebd 100644 --- a/tests/Equinox.EventStoreDb.Integration/StoreIntegration.fs +++ b/tests/Equinox.EventStoreDb.Integration/StoreIntegration.fs @@ -425,7 +425,7 @@ type GeneralTests(testOutputHelper) = let! before, after = let mapResult result (ctx: Equinox.ISyncContext<_>) = result, ctx.Version - decider.TransactEx((fun state -> state.Version, [| SimplestThing.StuffHappened |]), mapResult) + decider.TransactEx((fun c -> c.Version, [| SimplestThing.StuffHappened |]), mapResult = mapResult) test <@ [before; after] = [0L; 1L] @> } #if STORE_MESSAGEDB