Skip to content

Commit 732ec20

Browse files
committed
[UPDATE] fix readAllStream error.
1 parent c140704 commit 732ec20

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

Sources/KurrentDB/Streams/Usecase/All/Streams.ReadAll.swift

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,8 @@ extension Streams.ReadAll {
8787
package func build() -> UnderlyingMessage {
8888
.with {
8989
$0.noFilter = .init()
90-
90+
$0.all = .init()
91+
9192
switch uuidOption {
9293
case .structured:
9394
$0.uuidOption.structured = .init()
@@ -103,9 +104,9 @@ extension Streams.ReadAll {
103104

104105
switch position {
105106
case .start:
106-
$0.stream.start = .init()
107+
$0.all.start = .init()
107108
case .end:
108-
$0.stream.end = .init()
109+
$0.all.end = .init()
109110
case let .specified(commitPosition, preparePosition):
110111
$0.all.position = .with {
111112
$0.commitPosition = commitPosition

0 commit comments

Comments
 (0)