cn.katool.services.ai.common

类 KimiEventSourceLinsener

java.lang.Object

okhttp3.sse.EventSourceListener

cn.katool.services.ai.common.KimiEventSourceLinsener

public class KimiEventSourceLinsener
extends okhttp3.sse.EventSourceListener

字段概要

字段

限定符和类型	字段和说明
private Callable<okhttp3.sse.EventSource>	callBack
private CountDownLatch	eventLatch
private List<CommonAIMessage>	history
private StringBuilder	json
private java.util.function.Consumer<String>	kimiAiResponseDetail
(专用程序包) Map<String,java.util.function.Function<Map<String,String>,String>>	kimiFunctionDriverMap
private StringBuilder	localContent
private List<KimiAiToolCallsMessage>	messages
private String	upRole

构造器概要

构造器

构造器和说明
KimiEventSourceLinsener(java.util.function.Consumer<String> kimiAiResponseDetail, Callable callBack, Map<String,java.util.function.Function<Map<String,String>,String>> kimiFunctionDriverMap, List<CommonAIMessage> history, CountDownLatch eventLatch)

方法概要

限定符和类型	方法和说明
(专用程序包) void	addLocalContent(KimiChatResponse response)
private void	eventCancel(okhttp3.sse.EventSource eventSource)
void	onClosed(okhttp3.sse.EventSource eventSource)
void	onEvent(okhttp3.sse.EventSource eventSource, String id, String type, String data)
void	onFailure(okhttp3.sse.EventSource eventSource, Throwable t, okhttp3.Response response)
void	onOpen(okhttp3.sse.EventSource eventSource, okhttp3.Response response)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

upRole

private String upRole

localContent

private StringBuilder localContent

json

private StringBuilder json

kimiAiResponseDetail

private java.util.function.Consumer<String> kimiAiResponseDetail

history

private List<CommonAIMessage> history

callBack

private Callable<okhttp3.sse.EventSource> callBack

eventLatch

private volatile CountDownLatch eventLatch

kimiFunctionDriverMap

Map<String,java.util.function.Function<Map<String,String>,String>> kimiFunctionDriverMap

messages

private List<KimiAiToolCallsMessage> messages

构造器详细资料

KimiEventSourceLinsener

public KimiEventSourceLinsener(java.util.function.Consumer<String> kimiAiResponseDetail,
                               Callable callBack,
                               Map<String,java.util.function.Function<Map<String,String>,String>> kimiFunctionDriverMap,
                               List<CommonAIMessage> history,
                               CountDownLatch eventLatch)

方法详细资料

addLocalContent

void addLocalContent(KimiChatResponse response)

onClosed

public void onClosed(@NotNull
                     okhttp3.sse.EventSource eventSource)

覆盖:

onClosed 在类中 okhttp3.sse.EventSourceListener

onEvent

public void onEvent(@NotNull
                    okhttp3.sse.EventSource eventSource,
                    @Nullable
                    String id,
                    @Nullable
                    String type,
                    @NotNull
                    String data)

覆盖:

onEvent 在类中 okhttp3.sse.EventSourceListener

eventCancel

private void eventCancel(okhttp3.sse.EventSource eventSource)

onFailure

public void onFailure(@NotNull
                      okhttp3.sse.EventSource eventSource,
                      @Nullable
                      Throwable t,
                      @Nullable
                      okhttp3.Response response)

覆盖:

onFailure 在类中 okhttp3.sse.EventSourceListener

onOpen

public void onOpen(@NotNull
                   okhttp3.sse.EventSource eventSource,
                   @NotNull
                   okhttp3.Response response)

覆盖:

onOpen 在类中 okhttp3.sse.EventSourceListener