WIP - Ein Versuch (vielleicht Unsinn)

[demos/kafka/chat] / src / main / java / de / juplo / kafka / chat / backend / storage / files / FilesStorageStrategy.java

diff --git a/src/main/java/de/juplo/kafka/chat/backend/storage/files/FilesStorageStrategy.java b/src/main/java/de/juplo/kafka/chat/backend/storage/files/FilesStorageStrategy.java
index 1de0b44..45ca0e2 100644 (file)
--- a/src/main/java/de/juplo/kafka/chat/backend/storage/files/FilesStorageStrategy.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/storage/files/FilesStorageStrategy.java
@@ -62,24 +62,24 @@ public class FilesStorageStrategy implements StorageStrategy
               throw new RuntimeException(e);
             }
           })
-          .doOnTerminate(() ->
+          .doOnNext(chatRoomInfo ->
           {
             try
             {
-              generator.writeEndArray();
-              generator.close();
+              ChatRoomInfoTo chatRoomInfoTo = ChatRoomInfoTo.from(chatRoomInfo);
+              generator.writeObject(chatRoomInfoTo);
             }
             catch (IOException e)
             {
               throw new RuntimeException(e);
             }
           })
-          .subscribe(chatRoomInfo ->
+          .doOnTerminate(() ->
           {
             try
             {
-              ChatRoomInfoTo chatRoomInfoTo = ChatRoomInfoTo.from(chatRoomInfo);
-              generator.writeObject(chatRoomInfoTo);
+              generator.writeEndArray();
+              generator.close();
             }
             catch (IOException e)
             {