Skip to content

Commit ece9865

Browse files
author
Jamil Maqdis Anton
committed
Add AppendExtras.fs as a way to handle exceptions thrown by functions in Append.fs
1 parent 4841e58 commit ece9865

File tree

1 file changed

+26
-0
lines changed

1 file changed

+26
-0
lines changed

src/AppendExtras.fs

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
namespace SqlStreamStore.FSharp
2+
3+
open SqlStreamStore
4+
5+
module AppendExtras =
6+
let appendNewMessage (store: IStreamStore)
7+
(streamName: StreamName)
8+
(appendVersion: AppendVersion)
9+
(messageDetails: MessageDetails)
10+
: Async<Result<Streams.AppendResult, string>> =
11+
Append.appendNewMessage store streamName appendVersion messageDetails
12+
|> Async.Catch
13+
|> Async.map (function
14+
| Choice1Of2 response -> Ok response
15+
| Choice2Of2 exn -> Error exn.Message)
16+
17+
let appendNewMessages (store: IStreamStore)
18+
(streamName: StreamName)
19+
(appendVersion: AppendVersion)
20+
(messages: MessageDetails list)
21+
: Async<Result<Streams.AppendResult, string>> =
22+
Append.appendNewMessages store streamName appendVersion messages
23+
|> Async.Catch
24+
|> Async.map (function
25+
| Choice1Of2 response -> Ok response
26+
| Choice2Of2 exn -> Error exn.Message)

0 commit comments

Comments
 (0)