Fixes #254 and forgot to def chunk_size
This commit is contained in:
parent
f6d458e758
commit
99067c3e6f
1 changed files with 4 additions and 0 deletions
|
|
@ -10,6 +10,7 @@ Twitter API calls.
|
||||||
|
|
||||||
from .. import __version__
|
from .. import __version__
|
||||||
from ..compat import json, is_py3
|
from ..compat import json, is_py3
|
||||||
|
from ..helpers import _transparent_params
|
||||||
from .types import TwythonStreamerTypes
|
from .types import TwythonStreamerTypes
|
||||||
|
|
||||||
import requests
|
import requests
|
||||||
|
|
@ -88,6 +89,8 @@ class TwythonStreamer(object):
|
||||||
|
|
||||||
self.handlers = handlers if handlers else ['delete', 'limit', 'disconnect']
|
self.handlers = handlers if handlers else ['delete', 'limit', 'disconnect']
|
||||||
|
|
||||||
|
self.chunk_size = chunk_size
|
||||||
|
|
||||||
def _request(self, url, method='GET', params=None):
|
def _request(self, url, method='GET', params=None):
|
||||||
"""Internal stream request handling"""
|
"""Internal stream request handling"""
|
||||||
self.connected = True
|
self.connected = True
|
||||||
|
|
@ -95,6 +98,7 @@ class TwythonStreamer(object):
|
||||||
|
|
||||||
method = method.lower()
|
method = method.lower()
|
||||||
func = getattr(self.client, method)
|
func = getattr(self.client, method)
|
||||||
|
params, _ = _transparent_params(params)
|
||||||
|
|
||||||
def _send(retry_counter):
|
def _send(retry_counter):
|
||||||
requests_args = {}
|
requests_args = {}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue