From: Harmon Date: Sat, 23 Jan 2021 17:22:22 +0000 (-0600) Subject: Improve order of Stream methods X-Git-Url: https://vcs.fsf.org/?a=commitdiff_plain;h=1a3f49597bc0c59f22e217bc991aed0c46dd07b8;p=tweepy.git Improve order of Stream methods --- diff --git a/tweepy/streaming.py b/tweepy/streaming.py index 5f4d079..530ffe0 100644 --- a/tweepy/streaming.py +++ b/tweepy/streaming.py @@ -239,21 +239,6 @@ class Stream: else: self._run(*args, **kwargs) - def on_closed(self, resp): - """ Called when the response has been closed by Twitter """ - pass - - def sample(self, threaded=False, languages=None, stall_warnings=False): - params = {} - if self.running: - raise TweepError('Stream object already connected!') - endpoint = 'statuses/sample' - if languages: - params['language'] = ','.join(map(str, languages)) - if stall_warnings: - params['stall_warnings'] = 'true' - self._start(endpoint, params=params, threaded=threaded) - def filter(self, follow=None, track=None, threaded=False, locations=None, stall_warnings=False, languages=None, filter_level=None): body = {} @@ -277,5 +262,20 @@ class Stream: body['filter_level'] = filter_level self._start(endpoint, body=body, threaded=threaded) + def sample(self, threaded=False, languages=None, stall_warnings=False): + params = {} + if self.running: + raise TweepError('Stream object already connected!') + endpoint = 'statuses/sample' + if languages: + params['language'] = ','.join(map(str, languages)) + if stall_warnings: + params['stall_warnings'] = 'true' + self._start(endpoint, params=params, threaded=threaded) + def disconnect(self): self.running = False + + def on_closed(self, resp): + """ Called when the response has been closed by Twitter """ + pass