@@ -3,62 +3,70 @@ namespace SqlStreamStore.FSharp
3
3
open SqlStreamStore.Streams
4
4
5
5
module Read =
6
+ /// Read forwards from the all stream.
6
7
let allForwards ( store : SqlStreamStore.IStreamStore )
7
8
( startPositionInclusive : StartPosition )
8
9
( msgCount : int )
9
- : Async < Result < ReadAllPage , string >> =
10
+ : Async < Result < ReadAllPage , exn >> =
10
11
ReadRaw.allForwards store startPositionInclusive msgCount
11
12
|> ExceptionsHandler.asyncExceptionHandler
12
13
14
+ /// Read backwards from the all stream.
13
15
let allBackwards ( store : SqlStreamStore.IStreamStore )
14
16
( startPositionInclusive : StartPosition )
15
17
( msgCount : int )
16
- : Async < Result < ReadAllPage , string >> =
18
+ : Async < Result < ReadAllPage , exn >> =
17
19
ReadRaw.allBackwards store startPositionInclusive msgCount
18
20
|> ExceptionsHandler.asyncExceptionHandler
19
21
22
+ /// Read forwards from a specific stream.
20
23
let streamForwards ( store : SqlStreamStore.IStreamStore )
21
24
( streamName : string )
22
25
( readVersion : ReadVersion )
23
26
( msgCount : int )
24
- : Async < Result < ReadStreamPage , string >> =
27
+ : Async < Result < ReadStreamPage , exn >> =
25
28
ReadRaw.streamForwards store streamName readVersion msgCount
26
29
|> ExceptionsHandler.asyncExceptionHandler
27
30
31
+ /// Read backwards from a specific stream.
28
32
let streamBackwards ( store : SqlStreamStore.IStreamStore )
29
33
( streamName : string )
30
34
( readVersion : ReadVersion )
31
35
( msgCount : int )
32
- : Async < Result < ReadStreamPage , string >> =
36
+ : Async < Result < ReadStreamPage , exn >> =
33
37
ReadRaw.streamBackwards store streamName readVersion msgCount
34
38
|> ExceptionsHandler.asyncExceptionHandler
35
39
40
+ /// Read forwards from the all stream, prefetching the messages' jsonData.
36
41
let allForwardsPrefetch ( store : SqlStreamStore.IStreamStore )
37
42
( startPositionInclusive : StartPosition )
38
43
( msgCount : int )
39
- : Async < Result < ReadAllPage , string >> =
44
+ : Async < Result < ReadAllPage , exn >> =
40
45
ReadRaw.allForwardsPrefetch store startPositionInclusive msgCount true
41
46
|> ExceptionsHandler.asyncExceptionHandler
42
47
48
+ /// Read backwards from the all stream, prefetching the messages' jsonData.
43
49
let allBackwardsPrefetch ( store : SqlStreamStore.IStreamStore )
44
50
( startPositionInclusive : StartPosition )
45
51
( msgCount : int )
46
- : Async < Result < ReadAllPage , string >> =
52
+ : Async < Result < ReadAllPage , exn >> =
47
53
ReadRaw.allBackwardsPrefetch store startPositionInclusive msgCount true
48
54
|> ExceptionsHandler.asyncExceptionHandler
49
55
56
+ /// Read forwards from a specific stream, prefetching the messages' jsonData.
50
57
let streamForwardsPrefetch ( store : SqlStreamStore.IStreamStore )
51
58
( streamName : string )
52
59
( readVersion : ReadVersion )
53
60
( msgCount : int )
54
- : Async < Result < ReadStreamPage , string >> =
61
+ : Async < Result < ReadStreamPage , exn >> =
55
62
ReadRaw.streamForwardsPrefetch store streamName readVersion msgCount true
56
63
|> ExceptionsHandler.asyncExceptionHandler
57
64
65
+ /// Read backwards from a specific stream, prefetching the messages' jsonData.
58
66
let streamBackwardsPrefetch ( store : SqlStreamStore.IStreamStore )
59
67
( streamName : string )
60
68
( readVersion : ReadVersion )
61
69
( msgCount : int )
62
- : Async < Result < ReadStreamPage , string >> =
70
+ : Async < Result < ReadStreamPage , exn >> =
63
71
ReadRaw.streamBackwardsPrefetch store streamName readVersion msgCount true
64
72
|> ExceptionsHandler.asyncExceptionHandler
0 commit comments