@@ -1119,13 +1119,13 @@ type internal StoreCategory<'event, 'state, 'req>
11191119 let fold s xs = ( fold : Func< 'state, 'event[], 'state>) .Invoke( s, xs)
11201120 let fetch state f = task { let! token ' , events = f in return struct ( token', fold state events) }
11211121 let reload ( log , streamNam , requireLeader , ( Token.Unpack pos as streamToken ), state ) ct : Task < struct ( StreamToken * 'state )> = task {
1122- match ! store.Reload( log, ( streamNam, pos), requireLeader, ( codec.TryDecode , isOrigin), ct) with
1122+ match ! store.Reload( log, ( streamNam, pos), requireLeader, ( codec.Decode , isOrigin), ct) with
11231123 | LoadFromTokenResult.Unchanged -> return struct ( streamToken, state)
11241124 | LoadFromTokenResult.Found ( token', events) -> return token', fold state events }
11251125 interface ICategory< 'event, 'state, 'req> with
11261126 member _.Empty = Token.empty, initial
11271127 member _.Load ( log , _categoryName , _streamId , streamName , _maxAge , requireLeader , ct ) =
1128- fetch initial ( store.Load( log, ( streamName, None), requireLeader, ( codec.TryDecode , isOrigin), checkUnfolds, ct))
1128+ fetch initial ( store.Load( log, ( streamName, None), requireLeader, ( codec.Decode , isOrigin), checkUnfolds, ct))
11291129 member _.Sync ( log , _categoryName , _streamId , streamName , req , ( Token.Unpack pos as streamToken ), state , events , ct ) = task {
11301130 let state ' = fold state events
11311131 let exp , events , eventsEncoded , unfoldsEncoded =
0 commit comments