Remove FromMemento/CreateMemento

src/Equinox.CosmosStore/CosmosStore.fs

@@ -1487,12 +1487,6 @@ type CosmosStoreCategory<'event, 'state, 'context>
             let stream = resolveStream streamArgs option context
             Stream.ofMemento (Token.create streamId Position.fromKnownEmpty,initial) stream
 
-    member __.FromMemento(Token.Unpack (stream,_pos) as streamToken, state, [<O; D null>] ?context) =
-        let skipInitialization = None
-        let (categoryName, container, streamId, _maybeInit) = resolveStreamConfig (StreamName.parse stream)
-        let stream = resolveStream (categoryName, container, streamId, skipInitialization) context None
-        Stream.ofMemento (streamToken,state) stream
-
 namespace Equinox.CosmosStore.Core
 
 open Equinox.Core

src/Equinox.EventStore/EventStore.fs

@@ -632,10 +632,6 @@ type EventStoreCategory<'event, 'state, 'context>
         | sn, (None|Some AllowStale) -> resolveStream sn option context
         | sn, Some AssumeEmpty -> Stream.ofMemento (loadEmpty sn) (resolveStream sn option context)
 
-    /// Resolve from a Memento being used in a Continuation [based on position and state typically from Stream.CreateMemento]
-    member __.FromMemento(Token.Unpack token as streamToken, state, [<O; D null>] ?context) =
-        Stream.ofMemento (streamToken, state) (resolveStream token.stream.name context None)
-
 type private SerilogAdapter(log : ILogger) =
     interface EventStore.ClientAPI.ILogger with
         member __.Debug(format : string, args : obj []) =           log.Debug(format, args)

src/Equinox.MemoryStore/MemoryStore.fs

@@ -83,7 +83,3 @@ type MemoryStoreCategory<'event, 'state, 'Format, 'context>(store : VolatileStor
         match FsCodec.StreamName.toString streamName, option with
         | sn, (None | Some AllowStale) -> resolveStream sn context
         | sn, Some AssumeEmpty -> Stream.ofMemento (Token.ofEmpty sn, initial) (resolveStream sn context)
-
-    /// Resolve from a Memento being used in a Continuation [based on position and state typically from Stream.CreateMemento]
-    member _.FromMemento(Token.Unpack stream as streamToken, state, [<Optional; DefaultParameterValue null>] ?context) =
-        Stream.ofMemento (streamToken, state) (resolveStream stream.streamName context)

src/Equinox.SqlStreamStore/SqlStreamStore.fs

@@ -586,10 +586,6 @@ type SqlStreamStoreCategory<'event, 'state, 'context>
         | sn, (None|Some AllowStale) -> resolveStream sn option context
         | sn, Some AssumeEmpty -> Stream.ofMemento (loadEmpty sn) (resolveStream sn option context)
 
-    /// Resolve from a Memento being used in a Continuation [based on position and state typically from Stream.CreateMemento]
-    member __.FromMemento(Token.Unpack token as streamToken, state, [<O; D null>] ?context) =
-        Stream.ofMemento (streamToken,state) (resolveStream token.stream.name context None)
-
 [<AbstractClass>]
 type ConnectorBase([<O; D(null)>]?readRetryPolicy, [<O; D(null)>]?writeRetryPolicy) =
 

src/Equinox/Flow.fs

@@ -31,9 +31,6 @@ type IStream<'event, 'state> =
 /// Exposed by TransactEx / QueryEx, providing access to extended state information for cases where that's required
 type ISyncContext<'state> =
 
-    /// Represents a Checkpoint position on a Stream's timeline; Can be used to manage continuations via a Resolver's FromMemento method
-    abstract member CreateMemento : unit -> StreamToken * 'state
-
     /// Exposes the underlying Store's internal Version for the underlying stream.
     /// An empty stream is Version 0; one with a single event is Version 1 etc.
     /// It's important to consider that this Version is more authoritative than inspecting the `Index` of the last event passed to
@@ -62,7 +59,6 @@ module internal Flow =
                 return true }
 
         interface ISyncContext<'state> with
-            member __.CreateMemento() = tokenAndState
             member __.State = snd tokenAndState
             member __.Version = (fst tokenAndState).version