#NEWLINE# def _read_streams( self ) : #NEWLINE# #INDENT# paginator = self . logs_client . get_paginator ( 'filter_log_events' ) #NEWLINE# response_iterator = paginator . paginate ( logGroupName = self . log_group_name , startTime = self . start_ms , endTime = self . end_ms , interleaved = True , ** self . paginator_kwargs ) #NEWLINE# for page in response_iterator : #NEWLINE# #INDENT# for event in page [ 'events' ] : #NEWLINE# #INDENT# ( yield event )