>(){}.getType();
// res.embeddings = JsonUtils.fromJson(res.output.get("embeddings"), listType);
return res;
diff --git a/src/main/java/com/alibaba/dashscope/embeddings/TextEmbeddingSparseEmbedding.java b/src/main/java/com/alibaba/dashscope/embeddings/TextEmbeddingSparseEmbedding.java
index ba74326..1e094a4 100644
--- a/src/main/java/com/alibaba/dashscope/embeddings/TextEmbeddingSparseEmbedding.java
+++ b/src/main/java/com/alibaba/dashscope/embeddings/TextEmbeddingSparseEmbedding.java
@@ -2,7 +2,6 @@
import lombok.Data;
-
@Data
public class TextEmbeddingSparseEmbedding {
private Integer index;
diff --git a/src/main/java/com/alibaba/dashscope/multimodal/MultiModalDialog.java b/src/main/java/com/alibaba/dashscope/multimodal/MultiModalDialog.java
index 8dbd950..64c463b 100644
--- a/src/main/java/com/alibaba/dashscope/multimodal/MultiModalDialog.java
+++ b/src/main/java/com/alibaba/dashscope/multimodal/MultiModalDialog.java
@@ -1,11 +1,13 @@
package com.alibaba.dashscope.multimodal;
+import com.alibaba.dashscope.Version;
import com.alibaba.dashscope.api.SynchronizeFullDuplexApi;
import com.alibaba.dashscope.common.*;
import com.alibaba.dashscope.exception.ApiException;
import com.alibaba.dashscope.exception.InputRequiredException;
import com.alibaba.dashscope.exception.NoApiKeyException;
import com.alibaba.dashscope.protocol.ApiServiceOption;
+import com.alibaba.dashscope.protocol.ConnectionOptions;
import com.alibaba.dashscope.protocol.Protocol;
import com.alibaba.dashscope.protocol.StreamingMode;
import com.alibaba.dashscope.utils.JsonUtils;
@@ -13,12 +15,6 @@
import io.reactivex.BackpressureStrategy;
import io.reactivex.Emitter;
import io.reactivex.Flowable;
-import lombok.Builder;
-import lombok.Getter;
-import lombok.NonNull;
-import lombok.experimental.SuperBuilder;
-import lombok.extern.slf4j.Slf4j;
-
import java.nio.ByteBuffer;
import java.util.LinkedList;
import java.util.Objects;
@@ -26,13 +22,16 @@
import java.util.UUID;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicReference;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NonNull;
+import lombok.experimental.SuperBuilder;
+import lombok.extern.slf4j.Slf4j;
/**
- * Multimodal Dialog class responsible for handling various operations in multimodal
- * conversations.
+ * Multimodal Dialog class responsible for handling various operations in multimodal conversations.
*
- * author songsong.shao
- * date 2025/4/24
+ * author songsong.shao date 2025/4/24
*/
@Slf4j
public class MultiModalDialog {
@@ -42,6 +41,8 @@ public class MultiModalDialog {
private ApiServiceOption serviceOption; // Service option configuration
+ private ConnectionOptions connectionOptions;
+
private Emitter