fix(threads): 避免隐式订阅 events 流
This commit is contained in:
parent
f87f185bbd
commit
8dc57763f5
|
|
@ -193,14 +193,17 @@ export function useThreadStream({
|
||||||
handleStreamStart(meta.thread_id);
|
handleStreamStart(meta.thread_id);
|
||||||
setOnStreamThreadId(meta.thread_id);
|
setOnStreamThreadId(meta.thread_id);
|
||||||
},
|
},
|
||||||
onLangChainEvent(event) {
|
onLangChainEvent:
|
||||||
if (event.event === "on_tool_end") {
|
onToolEnd == null
|
||||||
listeners.current.onToolEnd?.({
|
? undefined
|
||||||
name: event.name,
|
: (event) => {
|
||||||
data: event.data,
|
if (event.event === "on_tool_end") {
|
||||||
});
|
listeners.current.onToolEnd?.({
|
||||||
}
|
name: event.name,
|
||||||
},
|
data: event.data,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
},
|
||||||
onUpdateEvent(data) {
|
onUpdateEvent(data) {
|
||||||
const updates: Array<Partial<AgentThreadState> | null> = Object.values(
|
const updates: Array<Partial<AgentThreadState> | null> = Object.values(
|
||||||
data || {},
|
data || {},
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue