Transform inputs to outputs.
Default implementation of atransform, which buffers input and calls astream.
Subclasses must override this method if they can start producing output while input is still being generated.
atransform(
self,
input: AsyncIterator[Input],
config: RunnableConfig | None = None,
**kwargs: Any | None = {}
) -> AsyncIterator[Output]| Name | Type | Description |
|---|---|---|
input* | AsyncIterator[Input] | An async 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 |