From 4374ec2f0b5030a3d234d8ee3d60e559e2ef3910 Mon Sep 17 00:00:00 2001 From: Aaron Hill Date: Tue, 8 Apr 2014 15:34:32 -0400 Subject: [PATCH] Don't add 'delimited=length' to self.parameters --- tweepy/streaming.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/tweepy/streaming.py b/tweepy/streaming.py index 33f1169..d7a6b6c 100644 --- a/tweepy/streaming.py +++ b/tweepy/streaming.py @@ -242,7 +242,7 @@ class Stream(object): def userstream(self, stall_warnings=False, _with=None, replies=None, track=None, locations=None, async=False, encoding='utf8'): - self.parameters = {'delimited': 'length'} + self.parameters = {} if self.running: raise TweepError('Stream object already connected!') self.url = '/%s/user.json?delimited=length' % STREAM_VERSION @@ -263,7 +263,7 @@ class Stream(object): self._start(async) def firehose(self, count=None, async=False): - self.parameters = {'delimited': 'length'} + self.parameters = {} if self.running: raise TweepError('Stream object already connected!') self.url = '/%s/statuses/firehose.json?delimited=length' % STREAM_VERSION @@ -272,14 +272,14 @@ class Stream(object): self._start(async) def retweet(self, async=False): - self.parameters = {'delimited': 'length'} + self.parameters = {} if self.running: raise TweepError('Stream object already connected!') self.url = '/%s/statuses/retweet.json?delimited=length' % STREAM_VERSION self._start(async) def sample(self, async=False): - self.parameters = {'delimited': 'length'} + self.parameters = {} if self.running: raise TweepError('Stream object already connected!') self.url = '/%s/statuses/sample.json?delimited=length' % STREAM_VERSION @@ -306,7 +306,6 @@ class Stream(object): if languages: self.parameters['language'] = ','.join(map(str, languages)) self.body = urlencode_noplus(self.parameters) - self.parameters['delimited'] = 'length' self._start(async) def disconnect(self): -- 2.25.1