hub / github.com/sqlalchemy/sqlalchemy / stream_scalars

Method stream_scalars

lib/sqlalchemy/ext/asyncio/session.py:691–699 · view source on GitHub ↗

(
        self,
        statement: TypedReturnsRows[Tuple[_T]],
        params: Optional[_CoreAnyExecuteParams] = None,
        *,
        execution_options: OrmExecuteOptionsParameter = util.EMPTY_DICT,
        bind_arguments: Optional[_BindArguments] = None,
        **kw: Any,
    )

Source from the content-addressed store, hash-verified

689
690	@overload
691	async def stream_scalars(
692	self,
693	statement: TypedReturnsRows[Tuple[_T]],
694	params: Optional[_CoreAnyExecuteParams] = None,
695	*,
696	execution_options: OrmExecuteOptionsParameter = util.EMPTY_DICT,
697	bind_arguments: Optional[_BindArguments] = None,
698	**kw: Any,
699	) -> AsyncScalarResult[_T]: ...
700
701	@overload
702	async def stream_scalars(

Callers 10

t_async_connection_stream_scalarsFunction · 0.45

t_async_session_stream_scalarsFunction · 0.45

asyncioFunction · 0.45

goFunction · 0.45

test_scalarsMethod · 0.45

test_server_side_required_for_scalarsMethod · 0.45

test_stream_scalars_ctxmanagerMethod · 0.45

test_aiterMethod · 0.45

test_scalarsMethod · 0.45

test_stream_fetch_many_not_completeMethod · 0.45

Calls 2

streamMethod · 0.95

scalarsMethod · 0.45

Tested by 6

test_scalarsMethod · 0.36

test_server_side_required_for_scalarsMethod · 0.36

test_stream_scalars_ctxmanagerMethod · 0.36

test_aiterMethod · 0.36

test_scalarsMethod · 0.36

test_stream_fetch_many_not_completeMethod · 0.36