code: def execute_request(self):
          
          if self.n_requests % 20 == 0 and self.n_requests > 1:
              logger.info("refreshing session")
              self.init_session()
  
          resp = request(session=self.session,
                         url=self.endpoint,
                         rule_payload=self.rule_payload)
          self.n_requests += 1
          ResultStream.session_request_counter += 1
          resp = json.loads(resp.content.decode(resp.encoding))
          self.next_token = resp.get("next", None)
          self.current_tweets = resp["results"]
docs: Sends the request to the API and parses the json response.
          Makes some assumptions about the session length and sets the presence
          of a "next" token.