Transform inputs to outputs.
Default implementation of transform, which buffers input and calls astream.
Subclasses must override this method if they can start producing output while input is still being generated.
transform(
self,
input: Iterator[Input],
config: RunnableConfig | None = None,
**kwargs: Any | None = {}
) -> Iterator[Output]| Name | Type | Description |
|---|---|---|
input* | Iterator[Input] | An iterator of inputs to the |
config | RunnableConfig | None | Default: NoneThe config to use for the |
**kwargs | Any | None | Default: {}Additional keyword arguments to pass to the |