X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fstorage%2Fmongodb%2FMessageRepositoryIT.java;h=06fddb2f5a301f8543180a17d38d66b04a18cbaf;hb=0e5178b7a3b8c8f3167f99c2d36452a2a68c80fa;hp=3e8a716088cfb63eb7190a98c332f29bcd843744;hpb=15273e71b69725fc536c3f1cbd49a4f2cf8afefa;p=demos%2Fkafka%2Fchat

diff --git a/src/test/java/de/juplo/kafka/chat/backend/storage/mongodb/MessageRepositoryIT.java b/src/test/java/de/juplo/kafka/chat/backend/storage/mongodb/MessageRepositoryIT.java
index 3e8a7160..06fddb2f 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/storage/mongodb/MessageRepositoryIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/storage/mongodb/MessageRepositoryIT.java
@@ -40,7 +40,7 @@ public class MessageRepositoryIT
   @BeforeEach
   public void setUp()
   {
-    repository.deleteAll();
+    repository.deleteAll().block();
 
     foo = UUID.randomUUID();
     bar = UUID.randomUUID();
@@ -54,64 +54,64 @@ public class MessageRepositoryIT
             Message.MessageKey.of("peter", 1l),
             serial++,
             now.plusSeconds(serial),
-            "Nachricht #" + serial)));
+            "Nachricht #" + serial))).block();
     foo_2 = repository.save(MessageTo.from(
         foo,
         new Message(
             Message.MessageKey.of("ute", 2l),
             serial++,
             now.plusSeconds(serial),
-            "Nachricht #" + serial)));
+            "Nachricht #" + serial))).block();
     bar_1 = repository.save(MessageTo.from(
         bar,
         new Message(
             Message.MessageKey.of("klaus", 1l),
             serial++,
             now.plusSeconds(serial),
-            "Nachricht #" + serial)));
+            "Nachricht #" + serial))).block();
     bar_2 = repository.save(MessageTo.from(
         bar,
         new Message(
             Message.MessageKey.of("beate", 2l),
             serial++,
             now.plusSeconds(serial),
-            "Nachricht #" + serial)));
+            "Nachricht #" + serial))).block();
     bar_3 = repository.save(MessageTo.from(
         bar,
         new Message(
             Message.MessageKey.of("peter", 3l),
             serial++,
             now.plusSeconds(serial),
-            "Nachricht #" + serial)));
+            "Nachricht #" + serial))).block();
   }
 
   @Test
   public void findsAll()
   {
-    assertThat(repository.findAll()).containsExactly(foo_1, foo_2, bar_1, bar_2, bar_3);
+    assertThat(repository.findAll()).emitsExactly(foo_1, foo_2, bar_1, bar_2, bar_3);
   }
 
   @Test
   public void findsByExample_chatRoomId()
   {
-    assertThat(repository.findAll(Example.of(new MessageTo(foo.toString(), null, null, null, null, null)))).containsExactly(foo_1, foo_2);
-    assertThat(repository.findAll(Example.of(new MessageTo(bar.toString(), null, null, null, null, null)))).containsExactly(bar_1, bar_2, bar_3);
+    assertThat(repository.findAll(Example.of(new MessageTo(foo.toString(), null, null, null, null, null)))).emitsExactly(foo_1, foo_2);
+    assertThat(repository.findAll(Example.of(new MessageTo(bar.toString(), null, null, null, null, null)))).emitsExactly(bar_1, bar_2, bar_3);
   }
 
   @Test
   public void findsByExample_user()
   {
-    assertThat(repository.findAll(Example.of(new MessageTo(null, "peter", null, null, null, null)))).containsExactly(foo_1, bar_3);
-    assertThat(repository.findAll(Example.of(new MessageTo(null, "klaus", null, null, null, null)))).containsExactly(bar_1);
-    assertThat(repository.findAll(Example.of(new MessageTo(null, "ute",   null, null, null, null)))).containsExactly(foo_2);
-    assertThat(repository.findAll(Example.of(new MessageTo(null, "beate", null, null, null, null)))).containsExactly(bar_2);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, "peter", null, null, null, null)))).emitsExactly(foo_1, bar_3);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, "klaus", null, null, null, null)))).emitsExactly(bar_1);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, "ute",   null, null, null, null)))).emitsExactly(foo_2);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, "beate", null, null, null, null)))).emitsExactly(bar_2);
   }
 
   @Test
   public void findsByExample_id()
   {
-    assertThat(repository.findAll(Example.of(new MessageTo(null, null, 1l, null, null, null)))).containsExactly(foo_1, bar_1);
-    assertThat(repository.findAll(Example.of(new MessageTo(null, null, 2l, null, null, null)))).containsExactly(foo_2, bar_2);
-    assertThat(repository.findAll(Example.of(new MessageTo(null, null, 3l, null, null, null)))).containsExactly(bar_3);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, null, 1l, null, null, null)))).emitsExactly(foo_1, bar_1);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, null, 2l, null, null, null)))).emitsExactly(foo_2, bar_2);
+    assertThat(repository.findAll(Example.of(new MessageTo(null, null, 3l, null, null, null)))).emitsExactly(bar_3);
   }
 }