astream

astream(
  self,
  input: InputT | Command | None,
  config: RunnableConfig | None = None,
  *,
  context: ContextT | None = None,
  stream_mode: StreamMode | list[StreamMode] | None = None,
  interrupt_before: All | Sequence[str] | None = None,
  interrupt_after: All | Sequence[str] | None = None,
  subgraphs: bool = False,
  version: Literal['v1', 'v2'] = 'v1'
) -> AsyncIterator[dict[str, Any] | Any]