Skip to content

Commit

Permalink
SDK 9 tweaks
Browse files Browse the repository at this point in the history
  • Loading branch information
bartelink committed Dec 16, 2024
1 parent bb97e02 commit caf11f8
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion src/Equinox.CosmosStore/CosmosStore.fs
Original file line number Diff line number Diff line change
Expand Up @@ -1484,7 +1484,7 @@ type EventsContext
member x.Read(streamName, [<O; D null>] ?ct, [<O; D null>] ?position, [<O; D null>] ?maxCount, [<O; D null>] ?direction): Task<Position*ITimelineEvent<EventBody>[]> =
x.GetInternal((streamName, position), ?ct = ct, ?maxCount = maxCount, ?direction = direction) |> yieldPositionAndData

[<System.Obsolete "Will be removed in V5 in favor of the overload that requires explict passing of the Unfolds">]
[<System.Obsolete "Will be removed in V5 in favor of the overload that requires explicit passing of the Unfolds">]
member x.Sync(streamName, position, events: IEventData<_>[], ct): Task<AppendResult<Position>> =
x.Sync(streamName, position, events, Array.empty, ct)

Expand Down
2 changes: 1 addition & 1 deletion src/Equinox.EventStoreDb/EventStoreDb.fs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
2 changes: 1 addition & 1 deletion tests/Equinox.EventStoreDb.Integration/StoreIntegration.fs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit caf11f8

Please sign in to comment.