def iter_describe_log_streams(
self,
*,
config_overrides: Optional[CloudWatchLogsClientConfig] = None,
log_group_name: Optional[
"capo_cloudwatch_logs.types.log_group_name.LogGroupName"
] = None,
log_group_identifier: Optional[
"capo_cloudwatch_logs.types.log_group_identifier.LogGroupIdentifier"
] = None,
log_stream_name_prefix: Optional[
"capo_cloudwatch_logs.types.log_stream_name.LogStreamName"
] = None,
order_by: Optional["capo_cloudwatch_logs.types.order_by.OrderBy"] = None,
descending: Optional["capo_cloudwatch_logs.types.descending.Descending"] = None,
next_token: Optional["capo_cloudwatch_logs.types.next_token.NextToken"] = None,
limit: Optional[
"capo_cloudwatch_logs.types.describe_limit.DescribeLimit"
] = None,
) -> "Iterator[capo_cloudwatch_logs.types.log_stream.LogStream]":
_token = next_token
while True:
_response = self.describe_log_streams(
config_overrides=config_overrides,
log_group_name=log_group_name,
log_group_identifier=log_group_identifier,
log_stream_name_prefix=log_stream_name_prefix,
order_by=order_by,
descending=descending,
next_token=_token,
limit=limit,
)
_page = _resolve_path(_response, ("log_streams",))
for _item in _page or []:
yield _item
_token = _resolve_path(_response, ("next_token",))
if not _token:
break