hub / github.com/sqlalchemy/sqlalchemy / stream

Method stream

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

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

Source from the content-addressed store, hash-verified

524
525	@overload
526	def stream(
527	self,
528	statement: TypedReturnsRows[Unpack[_Ts]],
529	parameters: Optional[_CoreAnyExecuteParams] = None,
530	*,
531	execution_options: Optional[CoreExecuteOptionsParameter] = None,
532	) -> GeneratorStartableContext[AsyncResult[Unpack[_Ts]]]: ...
533
534	@overload
535	def stream(

Callers 1

stream_scalarsMethod · 0.95

Calls 4

greenlet_spawnFunction · 0.85

AsyncResultClass · 0.85

merge_withMethod · 0.45

closeMethod · 0.45

Tested by

no test coverage detected