88from ...core .datetime_utils import serialize_datetime
99from ...core .http_response import AsyncHttpResponse , HttpResponse
1010from ...core .jsonable_encoder import jsonable_encoder
11- from ...core .pagination import AsyncPager , BaseHttpResponse , SyncPager
1211from ...core .request_options import RequestOptions
1312from ...core .unchecked_base_model import construct_type
1413from ...domains .types .domain import Domain
1514from ...domains .types .domain_id import DomainId
1615from ...domains .types .domain_name import DomainName
17- from ...domains .types .domain_summary import DomainSummary
1816from ...domains .types .feedback_enabled import FeedbackEnabled
1917from ...domains .types .list_domains_response import ListDomainsResponse
2018from ...errors .not_found_error import NotFoundError
@@ -48,7 +46,7 @@ def list(
4846 after : typing .Optional [After ] = None ,
4947 ascending : typing .Optional [Ascending ] = None ,
5048 request_options : typing .Optional [RequestOptions ] = None ,
51- ) -> SyncPager [ DomainSummary ]:
49+ ) -> HttpResponse [ ListDomainsResponse ]:
5250 """
5351 Parameters
5452 ----------
@@ -71,7 +69,7 @@ def list(
7169
7270 Returns
7371 -------
74- SyncPager[DomainSummary ]
72+ HttpResponse[ListDomainsResponse ]
7573 """
7674 _response = self ._client_wrapper .httpx_client .request (
7775 f"v0/pods/{ jsonable_encoder (pod_id )} /domains" ,
@@ -89,29 +87,14 @@ def list(
8987 )
9088 try :
9189 if 200 <= _response .status_code < 300 :
92- _parsed_response = typing .cast (
90+ _data = typing .cast (
9391 ListDomainsResponse ,
9492 construct_type (
9593 type_ = ListDomainsResponse , # type: ignore
9694 object_ = _response .json (),
9795 ),
9896 )
99- _items = _parsed_response .domains
100- _parsed_next = _parsed_response .next_page_token
101- _has_next = _parsed_next is not None and _parsed_next != ""
102- _get_next = lambda : self .list (
103- pod_id ,
104- limit = limit ,
105- page_token = _parsed_next ,
106- labels = labels ,
107- before = before ,
108- after = after ,
109- ascending = ascending ,
110- request_options = request_options ,
111- )
112- return SyncPager (
113- has_next = _has_next , items = _items , get_next = _get_next , response = BaseHttpResponse (response = _response )
114- )
97+ return HttpResponse (response = _response , data = _data )
11598 if _response .status_code == 404 :
11699 raise NotFoundError (
117100 headers = dict (_response .headers ),
@@ -247,7 +230,7 @@ async def list(
247230 after : typing .Optional [After ] = None ,
248231 ascending : typing .Optional [Ascending ] = None ,
249232 request_options : typing .Optional [RequestOptions ] = None ,
250- ) -> AsyncPager [ DomainSummary ]:
233+ ) -> AsyncHttpResponse [ ListDomainsResponse ]:
251234 """
252235 Parameters
253236 ----------
@@ -270,7 +253,7 @@ async def list(
270253
271254 Returns
272255 -------
273- AsyncPager[DomainSummary ]
256+ AsyncHttpResponse[ListDomainsResponse ]
274257 """
275258 _response = await self ._client_wrapper .httpx_client .request (
276259 f"v0/pods/{ jsonable_encoder (pod_id )} /domains" ,
@@ -288,32 +271,14 @@ async def list(
288271 )
289272 try :
290273 if 200 <= _response .status_code < 300 :
291- _parsed_response = typing .cast (
274+ _data = typing .cast (
292275 ListDomainsResponse ,
293276 construct_type (
294277 type_ = ListDomainsResponse , # type: ignore
295278 object_ = _response .json (),
296279 ),
297280 )
298- _items = _parsed_response .domains
299- _parsed_next = _parsed_response .next_page_token
300- _has_next = _parsed_next is not None and _parsed_next != ""
301-
302- async def _get_next ():
303- return await self .list (
304- pod_id ,
305- limit = limit ,
306- page_token = _parsed_next ,
307- labels = labels ,
308- before = before ,
309- after = after ,
310- ascending = ascending ,
311- request_options = request_options ,
312- )
313-
314- return AsyncPager (
315- has_next = _has_next , items = _items , get_next = _get_next , response = BaseHttpResponse (response = _response )
316- )
281+ return AsyncHttpResponse (response = _response , data = _data )
317282 if _response .status_code == 404 :
318283 raise NotFoundError (
319284 headers = dict (_response .headers ),
0 commit comments