AIDK API Reference / aidk-client / StreamProcessor

Class: StreamProcessor

Defined in: packages/client/src/execution-handler.ts:102

StreamProcessor - Framework-agnostic stream event processor

Handles:

• Message accumulation
• Text delta aggregation
• Tool call/result handling with automatic result patching
• Thread ID extraction

Constructors

Constructor

new StreamProcessor(callbacks: StreamProcessorCallbacks): StreamProcessor;

Defined in: packages/client/src/execution-handler.ts:109

Parameters

Parameter	Type
callbacks	StreamProcessorCallbacks

Returns

StreamProcessor

Methods

addMessage()

addMessage(message: Message): void;

Defined in: packages/client/src/execution-handler.ts:130

Add a message to the list

Parameters

Parameter	Type
message	Message

Returns

void

---

clear()

clear(): void;

Defined in: packages/client/src/execution-handler.ts:430

Clear all messages and reset state

Returns

void

---

getMessages()

getMessages(): Message[];

Defined in: packages/client/src/execution-handler.ts:116

Get current messages

Returns

Message[]

---

processEvent()

processEvent(
   event: EngineStreamEvent, 
   context: StreamEventContext, 
   addedAssistantMessage: boolean): {
  addedAssistantMessage: boolean;
};

Defined in: packages/client/src/execution-handler.ts:172

Process a stream event and update state

Parameters

Parameter	Type
event	EngineStreamEvent
context	StreamEventContext
addedAssistantMessage	boolean

Returns

{
  addedAssistantMessage: boolean;
}

Processing result with state updates

Name	Type	Defined in
addedAssistantMessage	boolean	packages/client/src/execution-handler.ts:176

---

setCurrentAssistantId()

setCurrentAssistantId(_id: string | null): void;

Defined in: packages/client/src/execution-handler.ts:123

Set the current assistant message ID being streamed (no-op, kept for API compatibility)

Parameters

Parameter	Type
_id	string | null

Returns

void

---

updateMessage()

updateMessage(id: string, updater: (message: Message) => Message): void;

Defined in: packages/client/src/execution-handler.ts:138

Update a message by ID

Parameters

Parameter	Type
id	string
updater	(message: Message) => Message

Returns

void