Helper method to transform an Iterator of Input values into an Iterator of
Output values, with callbacks.
Use this to implement stream() or transform() in Runnable subclasses.
_transformStreamWithConfig<
I extends any,
O extends ChatPromptValueInterface
>(
inputGenerator: AsyncGenerator<I>,
transformer: (generator: AsyncGenerator<I>, runManager: CallbackManagerForChainRun, options: Partial<RunnableConfig<Record<string, any>>>) => AsyncGenerator<O>, options: Partial<RunnableConfig<Record<string, any>>> __type
): AsyncGenerator<O>| Name | Type | Description |
|---|---|---|
inputGenerator* | AsyncGenerator<I> | |
transformer* | (generator: AsyncGenerator<I>, runManager?: CallbackManagerForChainRun, options?: Partial<RunnableConfig<Record<string, any>>>) => AsyncGenerator<O> | |
options | Partial<RunnableConfig<Record<string, any>>> & __type |