From 9f06a21b7aa6d8d8d04e25af443b9137f8ff812c Mon Sep 17 00:00:00 2001 From: Aaron Hill Date: Mon, 20 Jan 2014 19:43:05 -0500 Subject: [PATCH] Updated userstream parameters --- tweepy/streaming.py | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/tweepy/streaming.py b/tweepy/streaming.py index a95c0b4..b17b4f9 100644 --- a/tweepy/streaming.py +++ b/tweepy/streaming.py @@ -239,12 +239,26 @@ class Stream(object): """ Called when the response has been closed by Twitter """ pass - def userstream(self, count=None, async=False, secure=True): + def userstream(self, stall_warnings=False, _with=None, replies=None, + track=None, locations=None, async=False, encoding='utf8'): self.parameters = {'delimited': 'length'} if self.running: raise TweepError('Stream object already connected!') self.url = '/%s/user.json?delimited=length' % STREAM_VERSION self.host='userstream.twitter.com' + if stall_warnings: + self.parameters['stall_warnings'] = stall_warnings + if _with: + self.parameters['with'] = _with + if replies: + self.parameters['replies'] = replies + if locations and len(locations) > 0: + assert len(locations) % 4 == 0 + self.parameters['locations'] = ','.join(['%.2f' % l for l in locations]) + if track: + encoded_track = [s.encode(encoding) for s in track] + self.parameters['track'] = ','.join(encoded_track) + self.body = urlencode_noplus(self.parameters) self._start(async) def firehose(self, count=None, async=False): -- 2.25.1