@@ -6,14 +6,14 @@ open SqlStreamStore.Streams
66module Read =
77 let private fromReadVersion : uint -> int = fun readVersion -> int ( readVersion)
88
9- let readFromAllStreamAsync : SqlStreamStore.IStreamStore -> ReadingDirection -> StartPositionInclusive -> MessageCount -> Async < ReadAllPage > =
9+ let readFromAllStream : SqlStreamStore.IStreamStore -> ReadingDirection -> StartPositionInclusive -> MessageCount -> Async < ReadAllPage > =
1010 fun store readingDirection startPositionInclusive msgCount ->
1111 match readingDirection with
1212 | ReadingDirection.Forward -> store.ReadAllForwards( startPositionInclusive, msgCount)
1313 | ReadingDirection.Backward -> store.ReadAllBackwards( startPositionInclusive, msgCount)
1414 |> Async.AwaitTask
1515
16- let readFromAllStreamAsync ' : SqlStreamStore.IStreamStore -> ReadingDirection -> StartPositionInclusive -> MessageCount -> bool -> CancellationToken -> Async < ReadAllPage > =
16+ let readFromAllStream ' : SqlStreamStore.IStreamStore -> ReadingDirection -> StartPositionInclusive -> MessageCount -> bool -> CancellationToken -> Async < ReadAllPage > =
1717 fun store readingDirection startPositionInclusive msgCount prefetchJson cancellationToken ->
1818 match readingDirection with
1919 | ReadingDirection.Forward ->
@@ -22,32 +22,22 @@ module Read =
2222 store.ReadAllBackwards( startPositionInclusive, msgCount, prefetchJson, cancellationToken)
2323 |> Async.AwaitTask
2424
25- let readFromStreamAsync : SqlStreamStore.IStreamStore -> ReadingDirection -> StreamName -> ReadVersion -> MessageCount -> Async < ReadStreamPage > =
25+ let readFromStream : SqlStreamStore.IStreamStore -> ReadingDirection -> StreamName -> ReadVersion -> MessageCount -> Async < ReadStreamPage > =
2626 fun store readingDirection streamName readVersion msgCount ->
2727 match readingDirection with
2828 | ReadingDirection.Forward ->
29- store.ReadStreamForwards
30- ( StreamId( streamName), fromReadVersion readVersion, msgCount)
29+ store.ReadStreamForwards( StreamId( streamName), fromReadVersion readVersion, msgCount)
3130 | ReadingDirection.Backward ->
32- store.ReadStreamBackwards
33- ( StreamId( streamName), fromReadVersion readVersion, msgCount)
31+ store.ReadStreamBackwards( StreamId( streamName), fromReadVersion readVersion, msgCount)
3432 |> Async.AwaitTask
3533
36- let readFromStreamAsync ' : SqlStreamStore.IStreamStore -> ReadingDirection -> StreamName -> ReadVersion -> MessageCount -> bool -> CancellationToken -> Async < ReadStreamPage > =
34+ let readFromStream ' : SqlStreamStore.IStreamStore -> ReadingDirection -> StreamName -> ReadVersion -> MessageCount -> bool -> CancellationToken -> Async < ReadStreamPage > =
3735 fun store readingDirection streamName readVersion msgCount prefetchJson cancellationToken ->
3836 match readingDirection with
3937 | ReadingDirection.Forward ->
4038 store.ReadStreamForwards
41- ( StreamId( streamName),
42- fromReadVersion readVersion,
43- msgCount,
44- prefetchJson,
45- cancellationToken)
39+ ( StreamId( streamName), fromReadVersion readVersion, msgCount, prefetchJson, cancellationToken)
4640 | ReadingDirection.Backward ->
4741 store.ReadStreamBackwards
48- ( StreamId( streamName),
49- fromReadVersion readVersion,
50- msgCount,
51- prefetchJson,
52- cancellationToken)
42+ ( StreamId( streamName), fromReadVersion readVersion, msgCount, prefetchJson, cancellationToken)
5343 |> Async.AwaitTask
0 commit comments