MCPcopy
hub / github.com/sqlalchemy/sqlalchemy / stream

Method stream

lib/sqlalchemy/ext/asyncio/session.py:657–665  ·  view source on GitHub ↗
(
        self,
        statement: TypedReturnsRows[Unpack[_Ts]],
        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

655
656 @overload
657 async def stream(
658 self,
659 statement: TypedReturnsRows[Unpack[_Ts]],
660 params: Optional[_CoreAnyExecuteParams] = None,
661 *,
662 execution_options: OrmExecuteOptionsParameter = util.EMPTY_DICT,
663 bind_arguments: Optional[_BindArguments] = None,
664 **kw: Any,
665 ) -> AsyncResult[Unpack[_Ts]]: ...
666
667 @overload
668 async def stream(

Callers 15

stream_scalarsMethod · 0.95
t_async_result_scalar_accessorsFunction · 0.45
t_async_connection_stream_multiFunction · 0.45
t_async_connection_stream_singleFunction · 0.45
t_async_session_stream_multiFunction · 0.45
t_async_session_stream_singleFunction · 0.45
asyncioFunction · 0.45
test_stream_partitionsMethod · 0.45
test_server_side_required_for_scalarsMethod · 0.45
test_stream_ctxmanagerMethod · 0.45
test_allMethod · 0.45
test_aiterMethod · 0.45

Calls 3

greenlet_spawnFunction · 0.85
AsyncResultClass · 0.85
unionMethod · 0.45

Tested by 15

test_stream_partitionsMethod · 0.36
test_server_side_required_for_scalarsMethod · 0.36
test_stream_ctxmanagerMethod · 0.36
test_allMethod · 0.36
test_aiterMethod · 0.36
test_keysMethod · 0.36
test_unique_allMethod · 0.36
test_columns_allMethod · 0.36
test_partitionsMethod · 0.36
test_one_successMethod · 0.36
test_one_no_resultMethod · 0.36
test_one_multi_resultMethod · 0.36