MemoryKit

Stream Query

Stream a RAG response with Server-Sent Events.

Same parameters as Query Memories. Returns Server-Sent Events instead of a single JSON response.

Event types

EventDataDescription
text{ content: string }A chunk of the answer
sourcesSource[]Retrieved sources
usage{ tokens_used: number }Token usage
done{}Stream complete
error{ message: string }Error occurred

Example

for await (const event of mk.memories.stream({
  query: "What happened in our last meeting?",
  mode: "balanced",
})) {
  if (event.event === "text") {
    process.stdout.write(event.data.content);
  }
}

On this page