MCPcopy
hub / github.com/sqlalchemy/sqlalchemy / stream_scalars

Method stream_scalars

lib/sqlalchemy/ext/asyncio/session.py:710–718  ·  view source on GitHub ↗
(
        self,
        statement: TypedReturnsRows[_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

708
709 @overload
710 async def stream_scalars(
711 self,
712 statement: TypedReturnsRows[_T],
713 params: Optional[_CoreAnyExecuteParams] = None,
714 *,
715 execution_options: OrmExecuteOptionsParameter = util.EMPTY_DICT,
716 bind_arguments: Optional[_BindArguments] = None,
717 **kw: Any,
718 ) -> AsyncScalarResult[_T]: ...
719
720 @overload
721 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