def __init__(self, app_key, app_secret, oauth_token, oauth_token_secret,<EOL>timeout=<NUM_LIT>, retry_count=None, retry_in=<NUM_LIT:10>, client_args=None,<EOL>handlers=None, chunk_size=<NUM_LIT:1>):
self.auth = OAuth1(app_key, app_secret,<EOL>oauth_token, oauth_token_secret)<EOL>self.client_args = client_args or {}<EOL>default_headers = {'<STR_LIT>': '<STR_LIT>' + __version__}<EOL>if '<STR_LIT>' not in self.client_args:<EOL><INDENT>self.client_args['<STR_LIT>'] = default_headers<EOL><DEDENT>elif '<STR_LIT>' not in self.client_args['<STR_LIT>']:<EOL><INDENT>self.client_args['<STR_LIT>'].update(default_headers)<EOL><DEDENT>self.client_args['<STR_LIT>'] = timeout<EOL>self.client = requests.Session()<EOL>self.client.auth = self.auth<EOL>self.client.stream = True<EOL>client_args_copy = self.client_args.copy()<EOL>for k, v in client_args_copy.items():<EOL><INDENT>if k in ('<STR_LIT>', '<STR_LIT>', '<STR_LIT>', '<STR_LIT>', '<STR_LIT>'):<EOL><INDENT>setattr(self.client, k, v)<EOL>self.client_args.pop(k)  <EOL><DEDENT><DEDENT>self.api_version = '<STR_LIT>'<EOL>self.retry_in = retry_in<EOL>self.retry_count = retry_count<EOL>StreamTypes = TwythonStreamerTypes(self)<EOL>self.statuses = StreamTypes.statuses<EOL>self.user = StreamTypes.user<EOL>self.site = StreamTypes.site<EOL>self.connected = False<EOL>self.handlers = handlers if handlers else['<STR_LIT>', '<STR_LIT>', '<STR_LIT>']<EOL>self.chunk_size = chunk_size<EOL>
Streaming class for a friendly streaming user experience
        Authentication IS required to use the Twitter Streaming API

        :param app_key: (required) Your applications key
        :param app_secret: (required) Your applications secret key
        :param oauth_token: (required) Used with oauth_token_secret to make
                            authenticated calls
        :param oauth_token_secret: (required) Used with oauth_token to make
                                   authenticated calls
        :param timeout: (optional) How long (in secs) the streamer should wait
                        for a response from Twitter Streaming API
        :param retry_count: (optional) Number of times the API call should be
                            retired
        :param retry_in: (optional) Amount of time (in secs) the previous
                         API call should be tried again
        :param client_args: (optional) Accepts some requests Session
                            parameters and some requests Request parameters.
                            See
                            http://docs.python-requests.org/en/latest/api/#sessionapi
                            and requests section below it for details.
                            [ex. headers, proxies, verify(SSL verification)]
        :param handlers: (optional) Array of message types for which
                         corresponding handlers will be called

        :param chunk_size: (optional) Define the buffer size before data is
                           actually returned from the Streaming API. Default: 1