_transformStreamWithConfig<
I,
O
>(
inputGenerator: AsyncGenerator<I>,
transformer: (generator: | 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 |
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.