refactor

Author: Jamil Maqdis Anton

src/Read.fs

@@ -11,23 +11,25 @@ type ReadingDirection =
 
 module Read =
     let readFromStreamAsync: IStreamStore -> ReadingDirection -> StreamDetails -> int -> Async<ReadStreamPage> =
-        fun store direction stream msgCount ->
-            match direction with
-            | Forward -> store.ReadStreamForwards(stream.streamName, stream.position, msgCount)
-            | Backward -> store.ReadStreamBackwards(stream.streamName, stream.position, msgCount)
+        fun store readingDirection streamDetails msgCount ->
+            match readingDirection with
+            | Forward -> store.ReadStreamForwards(streamDetails.streamName, streamDetails.position, msgCount)
+            | Backward -> store.ReadStreamBackwards(streamDetails.streamName, streamDetails.position, msgCount)
             |> Async.AwaitTask
 
     let readFromStreamAsync': IStreamStore -> ReadingDirection -> StreamDetails -> int -> CancellationToken -> Async<ReadStreamPage> =
-        fun store direction stream msgCount cancellationToken ->
-            match direction with
-            | Forward -> store.ReadStreamForwards(stream.streamName, stream.position, msgCount, cancellationToken)
-            | Backward -> store.ReadStreamBackwards(stream.streamName, stream.position, msgCount, cancellationToken)
+        fun store readingDirection streamDetails msgCount cancellationToken ->
+            match readingDirection with
+            | Forward ->
+                store.ReadStreamForwards(streamDetails.streamName, streamDetails.position, msgCount, cancellationToken)
+            | Backward ->
+                store.ReadStreamBackwards(streamDetails.streamName, streamDetails.position, msgCount, cancellationToken)
             |> Async.AwaitTask
 
 module ReadExtras =
     let readStreamMessages: IStreamStore -> ReadingDirection -> StreamDetails -> int -> AsyncResult<List<StreamMessage>, string> =
-        fun store direction stream msgCount ->
-            Read.readFromStreamAsync store direction stream msgCount
+        fun store readingDirection streamDetails msgCount ->
+            Read.readFromStreamAsync store readingDirection streamDetails msgCount
             |> Async.bind (fun readStreamPage ->
                 readStreamPage.Messages
                 |> Seq.toList