code: def _get_total_read_size(self):
          
          if self.read_size:
              read_size = EVENT_SIZE * self.read_size
          else:
              read_size = EVENT_SIZE
          return read_size
docs: How much event data to process at once.