X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FAbstractStorageStrategyIT.java;h=74c7c6fd63809f49c15aa67259816c083c2c6dd3;hb=64ede95835a496e84857c38213dbf8ea451878e0;hp=7c9c07c36abdbca43f5866ac018d29c833efdc01;hpb=ed777a6fb33ffc8b2cdb6cf7df9cce51c39d44da;p=demos%2Fkafka%2Fchat

diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractStorageStrategyIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractStorageStrategyIT.java
index 7c9c07c3..74c7c6fd 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractStorageStrategyIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractStorageStrategyIT.java
@@ -40,7 +40,7 @@ public abstract class AbstractStorageStrategyIT
   {
     storageStrategy
         .write(chathome)
-        .subscribe();
+        .block();
   }
 
   @Test