projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
feat: Implemented problem-details for `UnknownChatroomException`
[demos/kafka/chat]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
chat
/
backend
/
persistence
/
LocalJsonFilesStorageStrategyIT.java
diff --git
a/src/test/java/de/juplo/kafka/chat/backend/persistence/LocalJsonFilesStorageStrategyIT.java
b/src/test/java/de/juplo/kafka/chat/backend/persistence/LocalJsonFilesStorageStrategyIT.java
index
8177881
..
c769222
100644
(file)
--- a/
src/test/java/de/juplo/kafka/chat/backend/persistence/LocalJsonFilesStorageStrategyIT.java
+++ b/
src/test/java/de/juplo/kafka/chat/backend/persistence/LocalJsonFilesStorageStrategyIT.java
@@
-18,7
+18,7
@@
import java.nio.file.Paths;
import java.time.Clock;
import java.util.List;
import java.time.Clock;
import java.util.List;
-import static
org.assertj.core.api.AssertionsForInterfaceTypes.assertThat
;
+import static
pl.rzrz.assertj.reactor.Assertions.*
;
@Slf4j
@Slf4j
@@
-61,14
+61,20
@@
public class LocalJsonFilesStorageStrategyIT
assertThat(chathome.list()).containsExactlyElementsOf(List.of(chatroom));
assertThat(chathome.getChatroom(chatroom.getId())).contains(chatroom);
assertThat(chathome.list()).containsExactlyElementsOf(List.of(chatroom));
assertThat(chathome.getChatroom(chatroom.getId())).contains(chatroom);
- assertThat(chathome.getChatroom(chatroom.getId()).get().getMessages().toStream()).containsExactlyElementsOf(List.of(m1, m2, m3, m4));
+ assertThat(chathome
+ .getChatroom(chatroom.getId())
+ .get()
+ .getMessages()).emitsExactly(m1, m2, m3, m4);
stop();
start();
assertThat(chathome.list()).containsExactlyElementsOf(List.of(chatroom));
assertThat(chathome.getChatroom(chatroom.getId())).contains(chatroom);
stop();
start();
assertThat(chathome.list()).containsExactlyElementsOf(List.of(chatroom));
assertThat(chathome.getChatroom(chatroom.getId())).contains(chatroom);
- assertThat(chathome.getChatroom(chatroom.getId()).get().getMessages().toStream()).containsExactlyElementsOf(List.of(m1, m2, m3, m4));
+ assertThat(chathome
+ .getChatroom(chatroom.getId())
+ .get()
+ .getMessages()).emitsExactly(m1, m2, m3, m4);
}
@BeforeEach
}
@BeforeEach