Skip to content

Commit 6fe22cb

Browse files
author
Jamil Maqdis Anton
committed
correct types
1 parent b3eb84f commit 6fe22cb

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

src/Read.fs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -14,33 +14,33 @@ module Read =
1414
let readFromAllStreamAsync: IStreamStore -> ReadingDirection -> StartPositionInclusive -> MessageCount -> Async<ReadAllPage> =
1515
fun store readingDirection startPositionInclusive msgCount ->
1616
match readingDirection with
17-
| Forward -> store.ReadAllForwards(startPositionInclusive, msgCount)
18-
| Backward -> store.ReadAllBackwards(startPositionInclusive, msgCount)
17+
| ReadingDirection.Forward -> store.ReadAllForwards(startPositionInclusive, msgCount)
18+
| ReadingDirection.Backward -> store.ReadAllBackwards(startPositionInclusive, msgCount)
1919
|> Async.AwaitTask
2020

2121
let readFromAllStreamAsync': IStreamStore -> ReadingDirection -> StartPositionInclusive -> MessageCount -> CancellationToken -> Async<ReadAllPage> =
2222
fun store readingDirection startPositionInclusive msgCount cancellationToken ->
2323
match readingDirection with
24-
| Forward -> store.ReadAllForwards(startPositionInclusive, msgCount, cancellationToken)
25-
| Backward -> store.ReadAllBackwards(startPositionInclusive, msgCount, cancellationToken)
24+
| ReadingDirection.Forward -> store.ReadAllForwards(startPositionInclusive, msgCount, cancellationToken)
25+
| ReadingDirection.Backward -> store.ReadAllBackwards(startPositionInclusive, msgCount, cancellationToken)
2626
|> Async.AwaitTask
2727

2828
let readFromStreamAsync: IStreamStore -> ReadingDirection -> StreamDetails -> MessageCount -> Async<ReadStreamPage> =
2929
fun store readingDirection streamDetails msgCount ->
3030
match readingDirection with
31-
| Forward ->
31+
| ReadingDirection.Forward ->
3232
store.ReadStreamForwards(streamDetails.streamName, Helpers.toVersion streamDetails.version, msgCount)
33-
| Backward ->
33+
| ReadingDirection.Backward ->
3434
store.ReadStreamBackwards(streamDetails.streamName, Helpers.toVersion streamDetails.version, msgCount)
3535
|> Async.AwaitTask
3636

3737
let readFromStreamAsync': IStreamStore -> ReadingDirection -> StreamDetails -> MessageCount -> CancellationToken -> Async<ReadStreamPage> =
3838
fun store readingDirection streamDetails msgCount cancellationToken ->
3939
match readingDirection with
40-
| Forward ->
40+
| ReadingDirection.Forward ->
4141
store.ReadStreamForwards
4242
(streamDetails.streamName, Helpers.toVersion streamDetails.version, msgCount, cancellationToken)
43-
| Backward ->
43+
| ReadingDirection.Backward ->
4444
store.ReadStreamBackwards
4545
(streamDetails.streamName, Helpers.toVersion streamDetails.version, msgCount, cancellationToken)
4646
|> Async.AwaitTask

0 commit comments

Comments
 (0)