Skip to content

Commit

Permalink
address feedback
Browse files Browse the repository at this point in the history
Signed-off-by: georgi-l95 <[email protected]>
  • Loading branch information
georgi-l95 committed Nov 14, 2024
1 parent 1226d52 commit 0f4fe61
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
6 changes: 1 addition & 5 deletions .gitignore
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@

# Mobile Tools for Java (J2ME)
.mtj.tmp/
bin/

# Package Files #
*.jar
Expand Down Expand Up @@ -58,8 +59,3 @@ server/src/test/resources/test_output/

# simulator files, this files are un-tarred before build
/simulator/src/main/resources/block-0.0.3/
/common/bin
/server/bin
/simulator/bin
/stream/bin
/suites/bin
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,8 @@
import java.util.ArrayList;
import java.util.List;

import static java.util.Objects.requireNonNull;

/**
* Represents the status of the stream.
*
Expand Down Expand Up @@ -87,7 +89,8 @@ public Builder consumedBlocks(int consumedBlocks) {
* @return the builder instance
*/
public Builder lastKnownPublisherStatuses(List<String> lastKnownPublisherStatuses) {
this.lastKnownPublisherStatuses = lastKnownPublisherStatuses;
requireNonNull(lastKnownPublisherStatuses);
this.lastKnownPublisherStatuses = new ArrayList<>(lastKnownPublisherStatuses);
return this;
}

Expand All @@ -98,7 +101,8 @@ public Builder lastKnownPublisherStatuses(List<String> lastKnownPublisherStatuse
* @return the builder instance
*/
public Builder lastKnownConsumersStatuses(List<String> lastKnownConsumersStatuses) {
this.lastKnownConsumersStatuses = lastKnownConsumersStatuses;
requireNonNull(lastKnownConsumersStatuses);
this.lastKnownConsumersStatuses = new ArrayList<>(lastKnownConsumersStatuses);
return this;
}

Expand Down

0 comments on commit 0f4fe61

Please sign in to comment.