Skip to content

Commit 55e64e7

Browse files
chore: use gapic-generator-python 0.52.0 (#31)
- [ ] Regenerate this pull request now. fix: improper types in pagers generation PiperOrigin-RevId: 399773015 Source-Link: googleapis/googleapis@410c184 Source-Link: googleapis/googleapis-gen@290e883 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMjkwZTg4MzU0NWUzYWM5ZmYyYmQwMGNkMGRhY2IyOGYxYjhjYTk0NSJ9
1 parent 9e70645 commit 55e64e7

File tree

1 file changed

+22
-22
lines changed
  • packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream

1 file changed

+22
-22
lines changed

packages/google-cloud-datastream/google/cloud/datastream_v1alpha1/services/datastream/pagers.py

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,13 @@
1515
#
1616
from typing import (
1717
Any,
18-
AsyncIterable,
18+
AsyncIterator,
1919
Awaitable,
2020
Callable,
21-
Iterable,
2221
Sequence,
2322
Tuple,
2423
Optional,
24+
Iterator,
2525
)
2626

2727
from google.cloud.datastream_v1alpha1.types import datastream
@@ -75,14 +75,14 @@ def __getattr__(self, name: str) -> Any:
7575
return getattr(self._response, name)
7676

7777
@property
78-
def pages(self) -> Iterable[datastream.ListConnectionProfilesResponse]:
78+
def pages(self) -> Iterator[datastream.ListConnectionProfilesResponse]:
7979
yield self._response
8080
while self._response.next_page_token:
8181
self._request.page_token = self._response.next_page_token
8282
self._response = self._method(self._request, metadata=self._metadata)
8383
yield self._response
8484

85-
def __iter__(self) -> Iterable[datastream_resources.ConnectionProfile]:
85+
def __iter__(self) -> Iterator[datastream_resources.ConnectionProfile]:
8686
for page in self.pages:
8787
yield from page.connection_profiles
8888

@@ -137,14 +137,14 @@ def __getattr__(self, name: str) -> Any:
137137
return getattr(self._response, name)
138138

139139
@property
140-
async def pages(self) -> AsyncIterable[datastream.ListConnectionProfilesResponse]:
140+
async def pages(self) -> AsyncIterator[datastream.ListConnectionProfilesResponse]:
141141
yield self._response
142142
while self._response.next_page_token:
143143
self._request.page_token = self._response.next_page_token
144144
self._response = await self._method(self._request, metadata=self._metadata)
145145
yield self._response
146146

147-
def __aiter__(self) -> AsyncIterable[datastream_resources.ConnectionProfile]:
147+
def __aiter__(self) -> AsyncIterator[datastream_resources.ConnectionProfile]:
148148
async def async_generator():
149149
async for page in self.pages:
150150
for response in page.connection_profiles:
@@ -203,14 +203,14 @@ def __getattr__(self, name: str) -> Any:
203203
return getattr(self._response, name)
204204

205205
@property
206-
def pages(self) -> Iterable[datastream.ListStreamsResponse]:
206+
def pages(self) -> Iterator[datastream.ListStreamsResponse]:
207207
yield self._response
208208
while self._response.next_page_token:
209209
self._request.page_token = self._response.next_page_token
210210
self._response = self._method(self._request, metadata=self._metadata)
211211
yield self._response
212212

213-
def __iter__(self) -> Iterable[datastream_resources.Stream]:
213+
def __iter__(self) -> Iterator[datastream_resources.Stream]:
214214
for page in self.pages:
215215
yield from page.streams
216216

@@ -265,14 +265,14 @@ def __getattr__(self, name: str) -> Any:
265265
return getattr(self._response, name)
266266

267267
@property
268-
async def pages(self) -> AsyncIterable[datastream.ListStreamsResponse]:
268+
async def pages(self) -> AsyncIterator[datastream.ListStreamsResponse]:
269269
yield self._response
270270
while self._response.next_page_token:
271271
self._request.page_token = self._response.next_page_token
272272
self._response = await self._method(self._request, metadata=self._metadata)
273273
yield self._response
274274

275-
def __aiter__(self) -> AsyncIterable[datastream_resources.Stream]:
275+
def __aiter__(self) -> AsyncIterator[datastream_resources.Stream]:
276276
async def async_generator():
277277
async for page in self.pages:
278278
for response in page.streams:
@@ -331,14 +331,14 @@ def __getattr__(self, name: str) -> Any:
331331
return getattr(self._response, name)
332332

333333
@property
334-
def pages(self) -> Iterable[datastream.FetchStaticIpsResponse]:
334+
def pages(self) -> Iterator[datastream.FetchStaticIpsResponse]:
335335
yield self._response
336336
while self._response.next_page_token:
337337
self._request.page_token = self._response.next_page_token
338338
self._response = self._method(self._request, metadata=self._metadata)
339339
yield self._response
340340

341-
def __iter__(self) -> Iterable[str]:
341+
def __iter__(self) -> Iterator[str]:
342342
for page in self.pages:
343343
yield from page.static_ips
344344

@@ -393,14 +393,14 @@ def __getattr__(self, name: str) -> Any:
393393
return getattr(self._response, name)
394394

395395
@property
396-
async def pages(self) -> AsyncIterable[datastream.FetchStaticIpsResponse]:
396+
async def pages(self) -> AsyncIterator[datastream.FetchStaticIpsResponse]:
397397
yield self._response
398398
while self._response.next_page_token:
399399
self._request.page_token = self._response.next_page_token
400400
self._response = await self._method(self._request, metadata=self._metadata)
401401
yield self._response
402402

403-
def __aiter__(self) -> AsyncIterable[str]:
403+
def __aiter__(self) -> AsyncIterator[str]:
404404
async def async_generator():
405405
async for page in self.pages:
406406
for response in page.static_ips:
@@ -459,14 +459,14 @@ def __getattr__(self, name: str) -> Any:
459459
return getattr(self._response, name)
460460

461461
@property
462-
def pages(self) -> Iterable[datastream.ListPrivateConnectionsResponse]:
462+
def pages(self) -> Iterator[datastream.ListPrivateConnectionsResponse]:
463463
yield self._response
464464
while self._response.next_page_token:
465465
self._request.page_token = self._response.next_page_token
466466
self._response = self._method(self._request, metadata=self._metadata)
467467
yield self._response
468468

469-
def __iter__(self) -> Iterable[datastream_resources.PrivateConnection]:
469+
def __iter__(self) -> Iterator[datastream_resources.PrivateConnection]:
470470
for page in self.pages:
471471
yield from page.private_connections
472472

@@ -521,14 +521,14 @@ def __getattr__(self, name: str) -> Any:
521521
return getattr(self._response, name)
522522

523523
@property
524-
async def pages(self) -> AsyncIterable[datastream.ListPrivateConnectionsResponse]:
524+
async def pages(self) -> AsyncIterator[datastream.ListPrivateConnectionsResponse]:
525525
yield self._response
526526
while self._response.next_page_token:
527527
self._request.page_token = self._response.next_page_token
528528
self._response = await self._method(self._request, metadata=self._metadata)
529529
yield self._response
530530

531-
def __aiter__(self) -> AsyncIterable[datastream_resources.PrivateConnection]:
531+
def __aiter__(self) -> AsyncIterator[datastream_resources.PrivateConnection]:
532532
async def async_generator():
533533
async for page in self.pages:
534534
for response in page.private_connections:
@@ -587,14 +587,14 @@ def __getattr__(self, name: str) -> Any:
587587
return getattr(self._response, name)
588588

589589
@property
590-
def pages(self) -> Iterable[datastream.ListRoutesResponse]:
590+
def pages(self) -> Iterator[datastream.ListRoutesResponse]:
591591
yield self._response
592592
while self._response.next_page_token:
593593
self._request.page_token = self._response.next_page_token
594594
self._response = self._method(self._request, metadata=self._metadata)
595595
yield self._response
596596

597-
def __iter__(self) -> Iterable[datastream_resources.Route]:
597+
def __iter__(self) -> Iterator[datastream_resources.Route]:
598598
for page in self.pages:
599599
yield from page.routes
600600

@@ -649,14 +649,14 @@ def __getattr__(self, name: str) -> Any:
649649
return getattr(self._response, name)
650650

651651
@property
652-
async def pages(self) -> AsyncIterable[datastream.ListRoutesResponse]:
652+
async def pages(self) -> AsyncIterator[datastream.ListRoutesResponse]:
653653
yield self._response
654654
while self._response.next_page_token:
655655
self._request.page_token = self._response.next_page_token
656656
self._response = await self._method(self._request, metadata=self._metadata)
657657
yield self._response
658658

659-
def __aiter__(self) -> AsyncIterable[datastream_resources.Route]:
659+
def __aiter__(self) -> AsyncIterator[datastream_resources.Route]:
660660
async def async_generator():
661661
async for page in self.pages:
662662
for response in page.routes:

0 commit comments

Comments
 (0)