hub / github.com/sqlalchemy/sqlalchemy / stream_scalars

Method stream_scalars

lib/sqlalchemy/ext/asyncio/engine.py:768–774 · view source on GitHub ↗

(
        self,
        statement: TypedReturnsRows[_T],
        parameters: Optional[_CoreSingleExecuteParams] = None,
        *,
        execution_options: Optional[CoreExecuteOptionsParameter] = None,
    )

Source from the content-addressed store, hash-verified

766
767	@overload
768	def stream_scalars(
769	self,
770	statement: TypedReturnsRows[_T],
771	parameters: Optional[_CoreSingleExecuteParams] = None,
772	*,
773	execution_options: Optional[CoreExecuteOptionsParameter] = None,
774	) -> GeneratorStartableContext[AsyncScalarResult[_T]]: ...
775
776	@overload
777	def stream_scalars(

Callers

nothing calls this directly

Calls 2

streamMethod · 0.95

scalarsMethod · 0.45

Tested by

no test coverage detected