Add docs. Change exception type.

Author: Jamil Maqdis Anton

src/Read.fs

@@ -3,7 +3,7 @@ namespace SqlStreamStore.FSharp
 open SqlStreamStore.Streams
 
 module Read =
-    /// Read forwards from the all stream. 
+    /// Read forwards from the all stream.
     let allForwards (store: SqlStreamStore.IStreamStore)
                     (startPositionInclusive: StartPosition)
                     (msgCount: int)
@@ -37,20 +37,20 @@ module Read =
         ReadRaw.streamBackwards store streamName readVersion msgCount
         |> ExceptionsHandler.asyncExceptionHandler
 
-    /// Read forwards from the all stream, prefetching the messages' jsonData. 
+    /// Read forwards from the all stream, prefetching the messages' jsonData.
     let allForwardsPrefetch (store: SqlStreamStore.IStreamStore)
                             (startPositionInclusive: StartPosition)
                             (msgCount: int)
                             : Async<Result<ReadAllPage, exn>> =
-        ReadRaw.allForwardsPrefetch store startPositionInclusive msgCount true
+        ReadRaw.allForwardsPrefetch store startPositionInclusive msgCount
         |> ExceptionsHandler.asyncExceptionHandler
 
-    /// Read backwards from the all stream, prefetching the messages' jsonData. 
+    /// Read backwards from the all stream, prefetching the messages' jsonData.
     let allBackwardsPrefetch (store: SqlStreamStore.IStreamStore)
                              (startPositionInclusive: StartPosition)
                              (msgCount: int)
                              : Async<Result<ReadAllPage, exn>> =
-        ReadRaw.allBackwardsPrefetch store startPositionInclusive msgCount true
+        ReadRaw.allBackwardsPrefetch store startPositionInclusive msgCount
         |> ExceptionsHandler.asyncExceptionHandler
 
     /// Read forwards from a specific stream, prefetching the messages' jsonData.
@@ -59,7 +59,7 @@ module Read =
                                (readVersion: ReadVersion)
                                (msgCount: int)
                                : Async<Result<ReadStreamPage, exn>> =
-        ReadRaw.streamForwardsPrefetch store streamName readVersion msgCount true
+        ReadRaw.streamForwardsPrefetch store streamName readVersion msgCount
         |> ExceptionsHandler.asyncExceptionHandler
 
     /// Read backwards from a specific stream, prefetching the messages' jsonData.
@@ -68,5 +68,5 @@ module Read =
                                 (readVersion: ReadVersion)
                                 (msgCount: int)
                                 : Async<Result<ReadStreamPage, exn>> =
-        ReadRaw.streamBackwardsPrefetch store streamName readVersion msgCount true
+        ReadRaw.streamBackwardsPrefetch store streamName readVersion msgCount
         |> ExceptionsHandler.asyncExceptionHandler

src/ReadRaw.fs

@@ -75,11 +75,10 @@ module ReadRaw =
     let allForwardsPrefetch (store: SqlStreamStore.IStreamStore)
                             (startPositionInclusive: StartPosition)
                             (msgCount: int)
-                            (prefetchJson: bool)
                             : Async<ReadAllPage> =
         async {
             return! store.ReadAllForwards
-                        (fromStartPositionInclusiveForwards startPositionInclusive, msgCount, prefetchJson)
+                        (fromStartPositionInclusiveForwards startPositionInclusive, msgCount, true)
                     |> Async.awaitTaskWithInnerException
         }
 
@@ -88,11 +87,10 @@ module ReadRaw =
     let allBackwardsPrefetch (store: SqlStreamStore.IStreamStore)
                              (startPositionInclusive: StartPosition)
                              (msgCount: int)
-                             (prefetchJson: bool)
                              : Async<ReadAllPage> =
         async {
             return! store.ReadAllBackwards
-                        (fromStartPositionInclusiveBackwards startPositionInclusive, msgCount, prefetchJson)
+                        (fromStartPositionInclusiveBackwards startPositionInclusive, msgCount, true)
                     |> Async.awaitTaskWithInnerException
         }
 
@@ -102,11 +100,10 @@ module ReadRaw =
                                (streamName: string)
                                (readVersion: ReadVersion)
                                (msgCount: int)
-                               (prefetchJson: bool)
                                : Async<ReadStreamPage> =
         async {
             return! store.ReadStreamForwards
-                        (StreamId(streamName), fromReadVersionForwards readVersion, msgCount, prefetchJson)
+                        (StreamId(streamName), fromReadVersionForwards readVersion, msgCount, true)
                     |> Async.awaitTaskWithInnerException
         }
 
@@ -116,11 +113,10 @@ module ReadRaw =
                                 (streamName: string)
                                 (readVersion: ReadVersion)
                                 (msgCount: int)
-                                (prefetchJson: bool)
                                 : Async<ReadStreamPage> =
         async {
             return! store.ReadStreamBackwards
-                        (StreamId(streamName), fromReadVersionBackwards readVersion, msgCount, prefetchJson)
+                        (StreamId(streamName), fromReadVersionBackwards readVersion, msgCount, true)
                     |> Async.awaitTaskWithInnerException
         }