X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FChatBackendApplication.java;h=0700496ee85856e2f58bb9ad4ffe0357a83342dc;hb=14c6a8c34de8b46b7f1655558727fc1276afb036;hp=37eeeee4110ab71c9847b0700a80d416053850a8;hpb=9e3e6397414722ad6f9a43381b4501edf4f56134;p=demos%2Fkafka%2Fchat

diff --git a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java
index 37eeeee4..0700496e 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/ChatBackendApplication.java
@@ -21,7 +21,7 @@ public class ChatBackendApplication
 	@PreDestroy
 	public void onExit()
 	{
-		storageStrategy.writeChatrooms(Flux.fromIterable(chatHome.list()));
+		storageStrategy.writeChatrooms(Flux.fromStream(chatHome.list()));
 	}
 
 	public static void main(String[] args)