Add read and prefetch functions

Author: Jamil Maqdis Anton

src/Read.fs

@@ -19,3 +19,20 @@ module Read =
                        : Async<Result<ReadStreamPage, string>> =
         ReadRaw.readFromStream store readingDirection streamName readVersion msgCount
         |> ExceptionsHandler.simpleExceptionHandler
+
+    let readFromAllStreamAndPrefetchJsonData (store: SqlStreamStore.IStreamStore)
+                                             (readingDirection: ReadingDirection)
+                                             (startPositionInclusive: StartPosition)
+                                             (msgCount: int)
+                                             : Async<Result<ReadAllPage, string>> =
+        ReadRaw.readFromAllStream' store readingDirection startPositionInclusive msgCount true
+        |> ExceptionsHandler.simpleExceptionHandler
+
+    let readFromStreamAndPrefetchJsonData (store: SqlStreamStore.IStreamStore)
+                                          (readingDirection: ReadingDirection)
+                                          (streamName: string)
+                                          (readVersion: ReadVersion)
+                                          (msgCount: int)
+                                          : Async<Result<ReadStreamPage, string>> =
+        ReadRaw.readFromStream' store readingDirection streamName readVersion msgCount true
+        |> ExceptionsHandler.simpleExceptionHandler

src/ReadRaw.fs

@@ -45,15 +45,12 @@ module ReadRaw =
                            (startPositionInclusive: StartPosition)
                            (msgCount: int)
                            (prefetchJson: bool)
-                           (cancellationToken: CancellationToken)
                            : Async<ReadAllPage> =
         match readingDirection with
         | ReadingDirection.Forward ->
-            store.ReadAllForwards
-                (fromStartPositionInclusive startPositionInclusive, msgCount, prefetchJson, cancellationToken)
+            store.ReadAllForwards(fromStartPositionInclusive startPositionInclusive, msgCount, prefetchJson)
         | ReadingDirection.Backward ->
-            store.ReadAllBackwards
-                (fromStartPositionInclusive startPositionInclusive, msgCount, prefetchJson, cancellationToken)
+            store.ReadAllBackwards(fromStartPositionInclusive startPositionInclusive, msgCount, prefetchJson)
         |> Async.AwaitTask
 
     let readFromStream' (store: SqlStreamStore.IStreamStore)
@@ -62,9 +59,39 @@ module ReadRaw =
                         (readVersion: ReadVersion)
                         (msgCount: int)
                         (prefetchJson: bool)
-                        (cancellationToken: CancellationToken)
                         : Async<ReadStreamPage> =
         match readingDirection with
+        | ReadingDirection.Forward ->
+            store.ReadStreamForwards(StreamId(streamName), fromReadVersion readVersion, msgCount, prefetchJson)
+        | ReadingDirection.Backward ->
+            store.ReadStreamBackwards(StreamId(streamName), fromReadVersion readVersion, msgCount, prefetchJson)
+        |> Async.AwaitTask
+
+    let readFromAllStream'' (store: SqlStreamStore.IStreamStore)
+                            (readingDirection: ReadingDirection)
+                            (startPositionInclusive: StartPosition)
+                            (msgCount: int)
+                            (prefetchJson: bool)
+                            (cancellationToken: CancellationToken)
+                            : Async<ReadAllPage> =
+        match readingDirection with
+        | ReadingDirection.Forward ->
+            store.ReadAllForwards
+                (fromStartPositionInclusive startPositionInclusive, msgCount, prefetchJson, cancellationToken)
+        | ReadingDirection.Backward ->
+            store.ReadAllBackwards
+                (fromStartPositionInclusive startPositionInclusive, msgCount, prefetchJson, cancellationToken)
+        |> Async.AwaitTask
+
+    let readFromStream'' (store: SqlStreamStore.IStreamStore)
+                         (readingDirection: ReadingDirection)
+                         (streamName: string)
+                         (readVersion: ReadVersion)
+                         (msgCount: int)
+                         (prefetchJson: bool)
+                         (cancellationToken: CancellationToken)
+                         : Async<ReadStreamPage> =
+        match readingDirection with
         | ReadingDirection.Forward ->
             store.ReadStreamForwards
                 (StreamId(streamName), fromReadVersion readVersion, msgCount, prefetchJson, cancellationToken)