atransform(
self,
input: AsyncIterator[Input],
config: RunnableConfig | None = None| 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: {} |
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.
Additional keyword arguments to pass to the Runnable.