Default implementation of stream, which calls invoke. Subclasses should override this method if they support streaming output.
(
self,
input: Input,
config: Optional[RunnableConfig] = None,
**kwargs: Optional[Any],
)
| 804 | yield await coro |
| 805 | |
| 806 | def stream( |
| 807 | self, |
| 808 | input: Input, |
| 809 | config: Optional[RunnableConfig] = None, |
| 810 | **kwargs: Optional[Any], |
| 811 | ) -> Iterator[Output]: |
| 812 | """ |
| 813 | Default implementation of stream, which calls invoke. |
| 814 | Subclasses should override this method if they support streaming output. |
| 815 | """ |
| 816 | yield self.invoke(input, config, **kwargs) |
| 817 | |
| 818 | async def astream( |
| 819 | self, |