repos/twython
1
Fork 0
Code Issues 23 Pull requests 4 Projects Releases 5 Packages Wiki Activity Actions

Fixes #230

Browse source
This commit is contained in:
Mike Helmick 2013-09-25 12:58:40 -04:00
parent 6da8805545
commit f6d458e758
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
twython/streaming/api.py
View file

@ -21,7 +21,7 @@ import time
class TwythonStreamer(object): class TwythonStreamer(object):
def __init__(self, app_key, app_secret, oauth_token, oauth_token_secret, def __init__(self, app_key, app_secret, oauth_token, oauth_token_secret,
timeout=300, retry_count=None, retry_in=10, client_args=None, timeout=300, retry_count=None, retry_in=10, client_args=None,
handlers=None): handlers=None, chunk_size=1):
"""Streaming class for a friendly streaming user experience """Streaming class for a friendly streaming user experience
Authentication IS required to use the Twitter Streaming API Authentication IS required to use the Twitter Streaming API
@ -42,6 +42,9 @@ class TwythonStreamer(object):
[ex. headers, proxies, verify(SSL verification)] [ex. headers, proxies, verify(SSL verification)]
:param handlers: (optional) Array of message types for which :param handlers: (optional) Array of message types for which
corresponding handlers will be called corresponding handlers will be called
:param chunk_size: (optional) Define the buffer size before data is
actually returned from the Streaming API. Default: 1
""" """
self.auth = OAuth1(app_key, app_secret, self.auth = OAuth1(app_key, app_secret,
@ -124,7 +127,7 @@ class TwythonStreamer(object):
while self.connected: while self.connected:
response = _send(retry_counter) response = _send(retry_counter)
for line in response.iter_lines(): for line in response.iter_lines(self.chunk_size):
if not self.connected: if not self.connected:
break break
if line: if line: