Skip to content

Commit 30e3e6b

Browse files
author
Jamil Maqdis Anton
committed
Add docs. Change exception type.
1 parent 09cfd7f commit 30e3e6b

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

src/ReadRaw.fs

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,7 @@ module ReadRaw =
7777
(msgCount: int)
7878
: Async<ReadAllPage> =
7979
async {
80-
return! store.ReadAllForwards
81-
(fromStartPositionInclusiveForwards startPositionInclusive, msgCount, true)
80+
return! store.ReadAllForwards(fromStartPositionInclusiveForwards startPositionInclusive, msgCount, true)
8281
|> Async.awaitTaskWithInnerException
8382
}
8483

@@ -89,8 +88,7 @@ module ReadRaw =
8988
(msgCount: int)
9089
: Async<ReadAllPage> =
9190
async {
92-
return! store.ReadAllBackwards
93-
(fromStartPositionInclusiveBackwards startPositionInclusive, msgCount, true)
91+
return! store.ReadAllBackwards(fromStartPositionInclusiveBackwards startPositionInclusive, msgCount, true)
9492
|> Async.awaitTaskWithInnerException
9593
}
9694

@@ -102,8 +100,7 @@ module ReadRaw =
102100
(msgCount: int)
103101
: Async<ReadStreamPage> =
104102
async {
105-
return! store.ReadStreamForwards
106-
(StreamId(streamName), fromReadVersionForwards readVersion, msgCount, true)
103+
return! store.ReadStreamForwards(StreamId(streamName), fromReadVersionForwards readVersion, msgCount, true)
107104
|> Async.awaitTaskWithInnerException
108105
}
109106

0 commit comments

Comments
 (0)