Function pipeGeneratorWithSetup

pipeGeneratorWithSetup<
    S,
    A extends unknown[],
    T,
    TReturn,
    TNext,
    U,
    UReturn,
    UNext,
>(
    to: (
        g: AsyncGenerator<T, TReturn, TNext>,
        s: S,
        ...args: A,
    ) => AsyncGenerator<U, UReturn, UNext>,
    generator: AsyncGenerator<T, TReturn, TNext>,
    startSetup: () => Promise<S>,
    signal: undefined | AbortSignal,
    ...args: A,
): Promise<{ output: AsyncGenerator<U, UReturn, UNext>; setup: Awaited<S> }>
Type Parameters
- S
- A extends unknown[]
- T
- TReturn
- TNext
- U
- UReturn
- UNext
Parameters
- to: (
      g: AsyncGenerator<T, TReturn, TNext>,
      s: S,
      ...args: A,
  ) => AsyncGenerator<U, UReturn, UNext>
- generator: AsyncGenerator<T, TReturn, TNext>
- startSetup: () => Promise<S>
- signal: undefined | AbortSignal
- ...args: A
Returns Promise<{ output: AsyncGenerator<U, UReturn, UNext>; setup: Awaited<S> }>
- Defined in remotes/langchain-ai/langchainjs/v1/libs/langchain-core/src/utils/stream.ts:279