if resp.raw.closed:
self.on_closed(resp)
- def _start(self, async):
+ def _start(self, is_async):
self.running = True
- if async:
+ if is_async:
self._thread = Thread(target=self._run)
self._thread.start()
else:
replies=None,
track=None,
locations=None,
- async=False,
+ is_async=False,
encoding='utf8'):
self.session.params = {'delimited': 'length'}
if self.running:
if track:
self.session.params['track'] = u','.join(track).encode(encoding)
- self._start(async)
+ self._start(is_async)
- def firehose(self, count=None, async=False):
+ def firehose(self, count=None, is_async=False):
self.session.params = {'delimited': 'length'}
if self.running:
raise TweepError('Stream object already connected!')
self.url = '/%s/statuses/firehose.json' % STREAM_VERSION
if count:
self.url += '&count=%s' % count
- self._start(async)
+ self._start(is_async)
- def retweet(self, async=False):
+ def retweet(self, is_async=False):
self.session.params = {'delimited': 'length'}
if self.running:
raise TweepError('Stream object already connected!')
self.url = '/%s/statuses/retweet.json' % STREAM_VERSION
- self._start(async)
+ self._start(is_async)
- def sample(self, async=False, languages=None, stall_warnings=False):
+ def sample(self, is_async=False, languages=None, stall_warnings=False):
self.session.params = {'delimited': 'length'}
if self.running:
raise TweepError('Stream object already connected!')
self.session.params['language'] = ','.join(map(str, languages))
if stall_warnings:
self.session.params['stall_warnings'] = 'true'
- self._start(async)
+ self._start(is_async)
- def filter(self, follow=None, track=None, async=False, locations=None,
+ def filter(self, follow=None, track=None, is_async=False, locations=None,
stall_warnings=False, languages=None, encoding='utf8', filter_level=None):
self.body = {}
self.session.headers['Content-type'] = "application/x-www-form-urlencoded"
self.body['filter_level'] = filter_level.encode(encoding)
self.session.params = {'delimited': 'length'}
self.host = 'stream.twitter.com'
- self._start(async)
+ self._start(is_async)
def sitestream(self, follow, stall_warnings=False,
- with_='user', replies=False, async=False):
+ with_='user', replies=False, is_async=False):
self.body = {}
if self.running:
raise TweepError('Stream object already connected!')
self.body['with'] = with_
if replies:
self.body['replies'] = replies
- self._start(async)
+ self._start(is_async)
def disconnect(self):
if self.running is False: