File tree Expand file tree Collapse file tree 1 file changed +1
-12
lines changed Expand file tree Collapse file tree 1 file changed +1
-12
lines changed Original file line number Diff line number Diff line change @@ -25,18 +25,7 @@ module Read =
2525 |> Async.AwaitTask
2626
2727module ReadExtras =
28- let readStreamMessages : IStreamStore -> ReadingDirection -> StreamDetails -> int -> Result < List < StreamMessage >, string > =
29- fun store direction stream msgCount ->
30- Read.readFromStreamAsync store direction stream msgCount
31- |> Async.RunSynchronously
32- |> fun readStreamPage -> readStreamPage.Messages
33- |> Seq.toList
34- |> fun messageList ->
35- if messageList.Length = msgCount
36- then Ok messageList
37- else Error( sprintf " Failed to retrieve all messages. Messages retrieved count: %d " messageList.Length)
38-
39- let readStreamMessages ' : IStreamStore -> ReadingDirection -> StreamDetails -> int -> AsyncResult < List < StreamMessage >, string > =
28+ let readStreamMessages : IStreamStore -> ReadingDirection -> StreamDetails -> int -> AsyncResult < List < StreamMessage >, string > =
4029 fun store direction stream msgCount ->
4130 Read.readFromStreamAsync store direction stream msgCount
4231 |> Async.bind ( fun readStreamPage ->
You can’t perform that action at this time.
0 commit comments