Skip to content

Commit a34627f

Browse files
author
Jamil Maqdis Anton
committed
Breakdown AppendStream, ReadStream record types to respective variables. Refactored accordingly
1 parent 58f8b15 commit a34627f

File tree

2 files changed

+14
-14
lines changed

2 files changed

+14
-14
lines changed

tests/AppendTests.fs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -12,27 +12,27 @@ let tests =
1212
[ testAsync "Should append one message to stream." {
1313
let inMemStore = new SqlStreamStore.InMemoryStreamStore()
1414

15-
let appendStream: AppendStreamDetails =
16-
{ streamName = "test"
17-
version = AppendVersion.NoStream }
15+
let streamName = "test"
16+
17+
let appendVersion = AppendVersion.NoStream
1818

1919
let msg =
2020
{ id = StreamMessageId.Auto
2121
type_ = "testing"
2222
jsonData = "{}"
2323
jsonMetadata = "{}" }
2424

25-
let! appendResult = Append.appendNewMessage inMemStore appendStream msg
25+
let! appendResult = Append.appendNewMessage inMemStore streamName appendVersion msg
2626

2727
ExpectExtra.equal 0 appendResult.CurrentVersion
2828
}
2929

3030
testAsync "Should append a list of messages to stream." {
3131
let inMemStore = new SqlStreamStore.InMemoryStreamStore()
3232

33-
let appendStream: AppendStreamDetails =
34-
{ streamName = "test"
35-
version = AppendVersion.NoStream }
33+
let streamName = "test"
34+
35+
let appendVersion = AppendVersion.NoStream
3636

3737
let msg1 =
3838
{ id = StreamMessageId.Auto
@@ -48,6 +48,6 @@ let tests =
4848

4949
let msgList = [ msg1; msg2 ]
5050

51-
let! appendResult = Append.appendNewMessages inMemStore appendStream msgList
51+
let! appendResult = Append.appendNewMessages inMemStore streamName appendVersion msgList
5252
ExpectExtra.equal 1 appendResult.CurrentVersion
5353
} ]

tests/ReadTests.fs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@ let tests =
1212
[ testAsync "Should read forward from specific stream." {
1313
let inMemStore = new SqlStreamStore.InMemoryStreamStore()
1414

15-
let appendStreamDetails: AppendStreamDetails =
16-
{ streamName = "test"
17-
version = AppendVersion.NoStream }
15+
let streamName = "test"
16+
17+
let appendVersion = AppendVersion.NoStream
1818

1919
let guidString1 = "11111111-1111-1111-1111-111111111111"
2020

@@ -34,12 +34,12 @@ let tests =
3434

3535
let msgList = [ msg1; msg2 ]
3636

37-
do! Append.appendNewMessages inMemStore appendStreamDetails msgList
37+
do! Append.appendNewMessages inMemStore streamName appendVersion msgList
3838
|> Async.Ignore
3939

40-
let readStreamDetails: ReadStreamDetails = { streamName = "test"; version = 0u }
40+
let readVersion = 0u
4141

42-
let! readResult = Read.readFromStreamAsync inMemStore ReadingDirection.Forward readStreamDetails 10
42+
let! readResult = Read.readFromStreamAsync inMemStore ReadingDirection.Forward streamName readVersion 10
4343

4444
readResult.Messages
4545
|> Array.sortBy (fun msg -> msg.MessageId)

0 commit comments

Comments
 (0)