|
15 | 15 | #
|
16 | 16 | from typing import (
|
17 | 17 | Any,
|
18 |
| - AsyncIterable, |
| 18 | + AsyncIterator, |
19 | 19 | Awaitable,
|
20 | 20 | Callable,
|
21 |
| - Iterable, |
22 | 21 | Sequence,
|
23 | 22 | Tuple,
|
24 | 23 | Optional,
|
| 24 | + Iterator, |
25 | 25 | )
|
26 | 26 |
|
27 | 27 | from google.cloud.workflows.executions_v1beta.types import executions
|
@@ -74,14 +74,14 @@ def __getattr__(self, name: str) -> Any:
|
74 | 74 | return getattr(self._response, name)
|
75 | 75 |
|
76 | 76 | @property
|
77 |
| - def pages(self) -> Iterable[executions.ListExecutionsResponse]: |
| 77 | + def pages(self) -> Iterator[executions.ListExecutionsResponse]: |
78 | 78 | yield self._response
|
79 | 79 | while self._response.next_page_token:
|
80 | 80 | self._request.page_token = self._response.next_page_token
|
81 | 81 | self._response = self._method(self._request, metadata=self._metadata)
|
82 | 82 | yield self._response
|
83 | 83 |
|
84 |
| - def __iter__(self) -> Iterable[executions.Execution]: |
| 84 | + def __iter__(self) -> Iterator[executions.Execution]: |
85 | 85 | for page in self.pages:
|
86 | 86 | yield from page.executions
|
87 | 87 |
|
@@ -136,14 +136,14 @@ def __getattr__(self, name: str) -> Any:
|
136 | 136 | return getattr(self._response, name)
|
137 | 137 |
|
138 | 138 | @property
|
139 |
| - async def pages(self) -> AsyncIterable[executions.ListExecutionsResponse]: |
| 139 | + async def pages(self) -> AsyncIterator[executions.ListExecutionsResponse]: |
140 | 140 | yield self._response
|
141 | 141 | while self._response.next_page_token:
|
142 | 142 | self._request.page_token = self._response.next_page_token
|
143 | 143 | self._response = await self._method(self._request, metadata=self._metadata)
|
144 | 144 | yield self._response
|
145 | 145 |
|
146 |
| - def __aiter__(self) -> AsyncIterable[executions.Execution]: |
| 146 | + def __aiter__(self) -> AsyncIterator[executions.Execution]: |
147 | 147 | async def async_generator():
|
148 | 148 | async for page in self.pages:
|
149 | 149 | for response in page.executions:
|
|
0 commit comments