Method
stream
(
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
| 636 | |
| 637 | @overload |
| 638 | async def stream( |
| 639 | self, |
| 640 | statement: TypedReturnsRows[_T], |
| 641 | params: Optional[_CoreAnyExecuteParams] = None, |
| 642 | *, |
| 643 | execution_options: OrmExecuteOptionsParameter = util.EMPTY_DICT, |
| 644 | bind_arguments: Optional[_BindArguments] = None, |
| 645 | **kw: Any, |
| 646 | ) -> AsyncResult[_T]: ... |
| 647 | |
| 648 | @overload |
| 649 | async def stream( |