Skip to content

Commit 89dfedf

Browse files
authored
split reading direction into two options (#15)
1 parent 692bcdb commit 89dfedf

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

src/Read.fs

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,22 +11,25 @@ type ReadPartialOption =
1111
| FromVersionInclusive of int
1212
| MessageCount of int
1313
| NoPrefetch
14-
| ReadDirection of ReadDirection
14+
| ReadForwards
15+
| ReadBackWards
1516

1617
[<RequireQualifiedAccess>]
1718
type ReadEntireOption =
1819
| CancellationToken of CancellationToken
1920
| FromVersionInclusive of int
2021
| NoPrefetch
21-
| ReadDirection of ReadDirection
22+
| ReadForwards
23+
| ReadBackWards
2224

2325
[<RequireQualifiedAccess>]
2426
type ReadAllOption =
2527
| CancellationToken of CancellationToken
2628
| FromPositionInclusive of int64
2729
| MessageCount of int
2830
| NoPrefetch
29-
| ReadDirection of ReadDirection
31+
| ReadForwards
32+
| ReadBackWards
3033

3134
module Read =
3235

@@ -45,7 +48,8 @@ module Read =
4548
| ReadPartialOption.FromVersionInclusive version -> fromVersionInclusive <- Some version
4649
| ReadPartialOption.MessageCount count -> messageCount <- count
4750
| ReadPartialOption.NoPrefetch -> prefetch <- false
48-
| ReadPartialOption.ReadDirection direction -> readDirection <- direction)
51+
| ReadPartialOption.ReadForwards -> readDirection <- ReadDirection.Forward
52+
| ReadPartialOption.ReadBackWards -> readDirection <- ReadDirection.Backward)
4953

5054
let fromVersionInclusive' =
5155
match readDirection, fromVersionInclusive with
@@ -90,12 +94,13 @@ module Read =
9094
| ReadEntireOption.CancellationToken token -> cancellationToken <- token
9195
| ReadEntireOption.FromVersionInclusive version -> fromVersionInclusive <- Some version
9296
| ReadEntireOption.NoPrefetch -> prefetch <- false
93-
| ReadEntireOption.ReadDirection direction -> readDirection <- direction)
97+
| ReadEntireOption.ReadForwards -> readDirection <- ReadDirection.Forward
98+
| ReadEntireOption.ReadBackWards -> readDirection <- ReadDirection.Backward)
9499

95100
let options =
96101
[
97102
ReadPartialOption.MessageCount System.Int32.MaxValue
98-
ReadPartialOption.ReadDirection readDirection
103+
ReadPartialOption.ReadForwards
99104
]
100105

101106
let options' =
@@ -131,7 +136,8 @@ module Read =
131136
| ReadAllOption.FromPositionInclusive position -> fromPositionInclusive <- Some position
132137
| ReadAllOption.MessageCount count -> messageCount <- count
133138
| ReadAllOption.NoPrefetch -> prefetch <- false
134-
| ReadAllOption.ReadDirection direction -> readDirection <- direction)
139+
| ReadAllOption.ReadForwards -> readDirection <- ReadDirection.Forward
140+
| ReadAllOption.ReadBackWards -> readDirection <- ReadDirection.Backward)
135141

136142
let fromPositionInclusive' =
137143
match readDirection, fromPositionInclusive with

0 commit comments

Comments
 (0)