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)
{