함수: replayRunStream()

function replayRunStream<TOffset>(
   durability, 
   offset?, 
signal?): AsyncGenerator<AGUIEvent>;

정의 위치: packages/ai/src/stream-durability.ts:588

실행의 전달 영속성 로그를 청크의 원시 스트림으로 재생합니다. HTTP Response 없이 joinRun 핸들러를 제공하는 호출자(예: async iterable을 반환하는 TanStack Start 서버 함수)를 위한 기능입니다.

async function* joinImageRun({ data: runId }: { data: string }) {
  yield* replayRunStream(memoryStream({ runId }))
}

// Serve it from a server function whose handler is the generator above
// (`createServerFn({ method: 'GET' }).inputValidator(...)`).

참고: 이 예제에서는 생성기를 server-fn 빌더 체인에 인라인하지 않고 별도로 선언합니다. TanStack Start의 server-fn Vite 플러그인은 SOURCE에서 점이 포함된 handler( 호출을 정규식으로 일치시켜 모듈을 컴파일해야 하는지 결정하며 JSDoc은 dist에 남습니다. 여기에 체인을 인라인하면 모든 Start 앱이 이 패키지를 server-fn 모듈로 처리하고 해당 프레임워크의 @tanstack/*-start 패키지를 확인하려고 하므로, 설치된 프레임워크가 해당 프레임워크가 아닌 곳에서는 빌드가 실패합니다.

offset(기본값 '-1', 처음부터)부터 읽고, 프로듀서가 로그를 닫거나 signal이 중단될 때까지 끝을 따라갑니다. HTTP resumeServerSentEventsResponse 경로와 정확히 동일합니다.

타입 매개변수

TOffset

TOffset extends string

매개변수

durability

StreamDurability<TOffset>

offset?

TOffset

signal?

AbortSignal

반환값

AsyncGenerator<AGUIEvent>