程序包 com.agentsflex.core.model.client

类 BaseStreamClientListener

java.lang.Object

com.agentsflex.core.model.client.BaseStreamClientListener

所有已实现的接口:

StreamClientListener

public class BaseStreamClientListener
extends Object
implements StreamClientListener

字段概要

字段

修饰符和类型	字段	说明
private final ChatContext	chatContext
private final StreamContext	context
private final AtomicBoolean	finishedFlag
private final AiMessage	fullMessage
private final AtomicBoolean	isFailure
private final AiMessageParser<com.alibaba.fastjson2.JSONObject>	messageParser
private final AtomicBoolean	stoppedFlag
private final StreamResponseListener	streamResponseListener

构造器概要

构造器

构造器	说明
BaseStreamClientListener(ChatModel chatModel, ChatContext chatContext, StreamClient client, StreamResponseListener streamResponseListener, AiMessageParser<com.alibaba.fastjson2.JSONObject> messageParser)

方法概要

修饰符和类型	方法	说明
private void	finalizeFullMessage()
private void	notifyLastMessage(String response)
private void	notifyLastMessageAndStop(String response)
void	onFailure(StreamClient client, Throwable throwable)
void	onMessage(StreamClient client, String response)
void	onStart(StreamClient client)
void	onStop(StreamClient client)

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

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

字段详细资料

streamResponseListener

private final StreamResponseListener streamResponseListener

chatContext

private final ChatContext chatContext

messageParser

private final AiMessageParser<com.alibaba.fastjson2.JSONObject> messageParser

context

private final StreamContext context

fullMessage

private final AiMessage fullMessage

finishedFlag

private final AtomicBoolean finishedFlag

stoppedFlag

private final AtomicBoolean stoppedFlag

isFailure

private final AtomicBoolean isFailure

构造器详细资料

BaseStreamClientListener

public BaseStreamClientListener(ChatModel chatModel,
 ChatContext chatContext,
 StreamClient client,
 StreamResponseListener streamResponseListener,
 AiMessageParser<com.alibaba.fastjson2.JSONObject> messageParser)

方法详细资料

onStart

public void onStart(StreamClient client)

指定者:

onStart 在接口中 StreamClientListener

onMessage

public void onMessage(StreamClient client,
 String response)

指定者:

onMessage 在接口中 StreamClientListener

notifyLastMessage

private void notifyLastMessage(String response)

notifyLastMessageAndStop

private void notifyLastMessageAndStop(String response)

onStop

public void onStop(StreamClient client)

指定者:

onStop 在接口中 StreamClientListener

finalizeFullMessage

private void finalizeFullMessage()

onFailure

public void onFailure(StreamClient client,
 Throwable throwable)

指定者:

onFailure 在接口中 StreamClientListener