createMessageResponse

Stream events for a newly created message.
import OpenAI from 'openai' import { createMessageResponse } from '@superinterface/react/server' const client = new OpenAI({ apiKey: process.env.OPENAI_API_KEY }) const threadId = 'thread_123' const createRunStream = await client.beta.threads.runs.create(threadId, { assistant_id: 'asst_123', stream: true, }) const stream = createMessageResponse({ client, createRunStream, handleToolCall: async () => {}, })

Arguments

ParameterTypeRequiredDescription
clientOpenAIYesOpenAI client instance
createRunStreamReadableStreamYesStream returned from client.beta.threads.runs.create
handleToolCallFunctionYesResolver for tool calls
onStartFunctionNoCalled when the stream opens
onErrorFunctionNoCalled when an error occurs
onCloseFunctionNoCalled when the stream closes
onEventFunctionNoCalled for each SSE event

Returns

A ReadableStream of server-sent events.