const reasoningAgent = mastra.getAgent("onboardingAgent");
const stream = await reasoningAgent.resumeStream(resumeData, { runId });
const uiMessageStream = createUIMessageStream({
originalMessages: messages,
execute: async ({ writer }) => {
for await (const part of toAISdkStream(stream, {
from: "agent",
})) {
await writer.write(part);
}
},
});
return createUIMessageStreamResponse({
stream: uiMessageStream,
});
const reasoningAgent = mastra.getAgent("onboardingAgent");
const stream = await reasoningAgent.resumeStream(resumeData, { runId });
const uiMessageStream = createUIMessageStream({
originalMessages: messages,
execute: async ({ writer }) => {
for await (const part of toAISdkStream(stream, {
from: "agent",
})) {
await writer.write(part);
}
},
});
return createUIMessageStreamResponse({
stream: uiMessageStream,
});