Default implementation of transform, which buffers input and then calls stream. Subclasses should override this method if they can start producing output while input is still being generated.
transform(
generator: AsyncGenerator<RunInput>,
options: Partial<RunnableConfig<Record<string, any>>>
): AsyncGenerator<RunOutput>| Name | Type | Description |
|---|---|---|
generator* | AsyncGenerator<RunInput> | |
options | Partial<RunnableConfig<Record<string, any>>> |