hub / github.com/sqlalchemy/sqlalchemy / stream

Method stream

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

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

Source from the content-addressed store, hash-verified

517
518	@overload
519	def stream(
520	self,
521	statement: TypedReturnsRows[_T],
522	parameters: Optional[_CoreAnyExecuteParams] = None,
523	*,
524	execution_options: Optional[CoreExecuteOptionsParameter] = None,
525	) -> GeneratorStartableContext[AsyncResult[_T]]: ...
526
527	@overload
528	def stream(

Callers 1

stream_scalarsMethod · 0.95

Calls 4

AsyncResultClass · 0.85

greenlet_spawnFunction · 0.50

merge_withMethod · 0.45

closeMethod · 0.45

Tested by

no test coverage detected