| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent dac5ce1 commit a56d004
3 files changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -15,13 +15,13 @@ | |||
| 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.pubsub_v1.types import pubsub | |
@@ -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[pubsub.ListTopicsResponse]: | ||
| 77 | + def pages(self) -> Iterator[pubsub.ListTopicsResponse]: | ||
| 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[pubsub.Topic]: | ||
| 84 | + def __iter__(self) -> Iterator[pubsub.Topic]: | ||
| 85 | 85 | for page in self.pages: | |
| 86 | 86 | yield from page.topics | |
| 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[pubsub.ListTopicsResponse]: | ||
| 139 | + async def pages(self) -> AsyncIterator[pubsub.ListTopicsResponse]: | ||
| 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[pubsub.Topic]: | ||
| 146 | + def __aiter__(self) -> AsyncIterator[pubsub.Topic]: | ||
| 147 | 147 | async def async_generator(): | |
| 148 | 148 | async for page in self.pages: | |
| 149 | 149 | for response in page.topics: | |
@@ -202,14 +202,14 @@ def __getattr__(self, name: str) -> Any: | |||
| 202 | 202 | return getattr(self._response, name) | |
| 203 | 203 | ||
| 204 | 204 | @property | |
| 205 | - def pages(self) -> Iterable[pubsub.ListTopicSubscriptionsResponse]: | ||
| 205 | + def pages(self) -> Iterator[pubsub.ListTopicSubscriptionsResponse]: | ||
| 206 | 206 | yield self._response | |
| 207 | 207 | while self._response.next_page_token: | |
| 208 | 208 | self._request.page_token = self._response.next_page_token | |
| 209 | 209 | self._response = self._method(self._request, metadata=self._metadata) | |
| 210 | 210 | yield self._response | |
| 211 | 211 | ||
| 212 | - def __iter__(self) -> Iterable[str]: | ||
| 212 | + def __iter__(self) -> Iterator[str]: | ||
| 213 | 213 | for page in self.pages: | |
| 214 | 214 | yield from page.subscriptions | |
| 215 | 215 | ||
@@ -264,14 +264,14 @@ def __getattr__(self, name: str) -> Any: | |||
| 264 | 264 | return getattr(self._response, name) | |
| 265 | 265 | ||
| 266 | 266 | @property | |
| 267 | - async def pages(self) -> AsyncIterable[pubsub.ListTopicSubscriptionsResponse]: | ||
| 267 | + async def pages(self) -> AsyncIterator[pubsub.ListTopicSubscriptionsResponse]: | ||
| 268 | 268 | yield self._response | |
| 269 | 269 | while self._response.next_page_token: | |
| 270 | 270 | self._request.page_token = self._response.next_page_token | |
| 271 | 271 | self._response = await self._method(self._request, metadata=self._metadata) | |
| 272 | 272 | yield self._response | |
| 273 | 273 | ||
| 274 | - def __aiter__(self) -> AsyncIterable[str]: | ||
| 274 | + def __aiter__(self) -> AsyncIterator[str]: | ||
| 275 | 275 | async def async_generator(): | |
| 276 | 276 | async for page in self.pages: | |
| 277 | 277 | for response in page.subscriptions: | |
@@ -330,14 +330,14 @@ def __getattr__(self, name: str) -> Any: | |||
| 330 | 330 | return getattr(self._response, name) | |
| 331 | 331 | ||
| 332 | 332 | @property | |
| 333 | - def pages(self) -> Iterable[pubsub.ListTopicSnapshotsResponse]: | ||
| 333 | + def pages(self) -> Iterator[pubsub.ListTopicSnapshotsResponse]: | ||
| 334 | 334 | yield self._response | |
| 335 | 335 | while self._response.next_page_token: | |
| 336 | 336 | self._request.page_token = self._response.next_page_token | |
| 337 | 337 | self._response = self._method(self._request, metadata=self._metadata) | |
| 338 | 338 | yield self._response | |
| 339 | 339 | ||
| 340 | - def __iter__(self) -> Iterable[str]: | ||
| 340 | + def __iter__(self) -> Iterator[str]: | ||
| 341 | 341 | for page in self.pages: | |
| 342 | 342 | yield from page.snapshots | |
| 343 | 343 | ||
@@ -392,14 +392,14 @@ def __getattr__(self, name: str) -> Any: | |||
| 392 | 392 | return getattr(self._response, name) | |
| 393 | 393 | ||
| 394 | 394 | @property | |
| 395 | - async def pages(self) -> AsyncIterable[pubsub.ListTopicSnapshotsResponse]: | ||
| 395 | + async def pages(self) -> AsyncIterator[pubsub.ListTopicSnapshotsResponse]: | ||
| 396 | 396 | yield self._response | |
| 397 | 397 | while self._response.next_page_token: | |
| 398 | 398 | self._request.page_token = self._response.next_page_token | |
| 399 | 399 | self._response = await self._method(self._request, metadata=self._metadata) | |
| 400 | 400 | yield self._response | |
| 401 | 401 | ||
| 402 | - def __aiter__(self) -> AsyncIterable[str]: | ||
| 402 | + def __aiter__(self) -> AsyncIterator[str]: | ||
| 403 | 403 | async def async_generator(): | |
| 404 | 404 | async for page in self.pages: | |
| 405 | 405 | for response in page.snapshots: | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -15,13 +15,13 @@ | |||
| 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.pubsub_v1.types import schema | |
@@ -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[schema.ListSchemasResponse]: | ||
| 77 | + def pages(self) -> Iterator[schema.ListSchemasResponse]: | ||
| 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[schema.Schema]: | ||
| 84 | + def __iter__(self) -> Iterator[schema.Schema]: | ||
| 85 | 85 | for page in self.pages: | |
| 86 | 86 | yield from page.schemas | |
| 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[schema.ListSchemasResponse]: | ||
| 139 | + async def pages(self) -> AsyncIterator[schema.ListSchemasResponse]: | ||
| 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[schema.Schema]: | ||
| 146 | + def __aiter__(self) -> AsyncIterator[schema.Schema]: | ||
| 147 | 147 | async def async_generator(): | |
| 148 | 148 | async for page in self.pages: | |
| 149 | 149 | for response in page.schemas: | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -15,13 +15,13 @@ | |||
| 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.pubsub_v1.types import pubsub | |
@@ -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[pubsub.ListSubscriptionsResponse]: | ||
| 77 | + def pages(self) -> Iterator[pubsub.ListSubscriptionsResponse]: | ||
| 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[pubsub.Subscription]: | ||
| 84 | + def __iter__(self) -> Iterator[pubsub.Subscription]: | ||
| 85 | 85 | for page in self.pages: | |
| 86 | 86 | yield from page.subscriptions | |
| 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[pubsub.ListSubscriptionsResponse]: | ||
| 139 | + async def pages(self) -> AsyncIterator[pubsub.ListSubscriptionsResponse]: | ||
| 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[pubsub.Subscription]: | ||
| 146 | + def __aiter__(self) -> AsyncIterator[pubsub.Subscription]: | ||
| 147 | 147 | async def async_generator(): | |
| 148 | 148 | async for page in self.pages: | |
| 149 | 149 | for response in page.subscriptions: | |
@@ -202,14 +202,14 @@ def __getattr__(self, name: str) -> Any: | |||
| 202 | 202 | return getattr(self._response, name) | |
| 203 | 203 | ||
| 204 | 204 | @property | |
| 205 | - def pages(self) -> Iterable[pubsub.ListSnapshotsResponse]: | ||
| 205 | + def pages(self) -> Iterator[pubsub.ListSnapshotsResponse]: | ||
| 206 | 206 | yield self._response | |
| 207 | 207 | while self._response.next_page_token: | |
| 208 | 208 | self._request.page_token = self._response.next_page_token | |
| 209 | 209 | self._response = self._method(self._request, metadata=self._metadata) | |
| 210 | 210 | yield self._response | |
| 211 | 211 | ||
| 212 | - def __iter__(self) -> Iterable[pubsub.Snapshot]: | ||
| 212 | + def __iter__(self) -> Iterator[pubsub.Snapshot]: | ||
| 213 | 213 | for page in self.pages: | |
| 214 | 214 | yield from page.snapshots | |
| 215 | 215 | ||
@@ -264,14 +264,14 @@ def __getattr__(self, name: str) -> Any: | |||
| 264 | 264 | return getattr(self._response, name) | |
| 265 | 265 | ||
| 266 | 266 | @property | |
| 267 | - async def pages(self) -> AsyncIterable[pubsub.ListSnapshotsResponse]: | ||
| 267 | + async def pages(self) -> AsyncIterator[pubsub.ListSnapshotsResponse]: | ||
| 268 | 268 | yield self._response | |
| 269 | 269 | while self._response.next_page_token: | |
| 270 | 270 | self._request.page_token = self._response.next_page_token | |
| 271 | 271 | self._response = await self._method(self._request, metadata=self._metadata) | |
| 272 | 272 | yield self._response | |
| 273 | 273 | ||
| 274 | - def __aiter__(self) -> AsyncIterable[pubsub.Snapshot]: | ||
| 274 | + def __aiter__(self) -> AsyncIterator[pubsub.Snapshot]: | ||
| 275 | 275 | async def async_generator(): | |
| 276 | 276 | async for page in self.pages: | |
| 277 | 277 | for response in page.snapshots: | |
| Back | FazBrowse Home | New Git URL |
0 commit comments