WIP

Author: Jamil Maqdis Anton

src/Read.fs

@@ -1,5 +1,6 @@
 namespace SqlStreamStore.FSharp
 
+open System.Threading
 open SqlStreamStore
 open SqlStreamStore.Streams
 
@@ -13,4 +14,11 @@ module Read =
             match direction with
             | Forward -> conn.ReadStreamForwards(stream.streamName, stream.position, msgCount)
             | Backward -> conn.ReadStreamBackwards(stream.streamName, stream.position, msgCount)
-            |> Async.AwaitTask
+            |> Async.AwaitTask
+
+    let readFromStreamAsync': IStreamStore -> ReadingDirection -> StreamDetails -> int -> CancellationToken -> Async<ReadStreamPage> =
+        fun conn direction stream msgCount cancellationToken ->
+            match direction with
+            | Forward -> conn.ReadStreamForwards(stream.streamName, stream.position, msgCount, cancellationToken)
+            | Backward -> conn.ReadStreamBackwards(stream.streamName, stream.position, msgCount, cancellationToken)
+            |> Async.AwaitTask