From: Harmon <Harmon758@gmail.com>
Date: Fri, 22 Jan 2021 18:39:48 +0000 (-0600)
Subject: Rename is_async Stream.filter and Stream.sample parameters to threaded
X-Git-Url: https://vcs.fsf.org/?a=commitdiff_plain;h=6c96c156cac4ede3855222f0c4705bc08829b308;p=tweepy.git

Rename is_async Stream.filter and Stream.sample parameters to threaded
---

diff --git a/tweepy/streaming.py b/tweepy/streaming.py
index b4a9c44..dcf7004 100644
--- a/tweepy/streaming.py
+++ b/tweepy/streaming.py
@@ -237,9 +237,9 @@ class Stream:
         if resp.raw.closed:
             self.on_closed(resp)
 
-    def _start(self, is_async, *args, **kwargs):
+    def _start(self, threaded, *args, **kwargs):
         self.running = True
-        if is_async:
+        if threaded:
             self._thread = Thread(target=self._run, args=args, kwargs=kwargs)
             self._thread.daemon = self.daemon
             self._thread.start()
@@ -250,7 +250,7 @@ class Stream:
         """ Called when the response has been closed by Twitter """
         pass
 
-    def sample(self, is_async=False, languages=None, stall_warnings=False):
+    def sample(self, threaded=False, languages=None, stall_warnings=False):
         self.session.params = {}
         if self.running:
             raise TweepError('Stream object already connected!')
@@ -259,9 +259,9 @@ class Stream:
             self.session.params['language'] = ','.join(map(str, languages))
         if stall_warnings:
             self.session.params['stall_warnings'] = 'true'
-        self._start(is_async)
+        self._start(threaded)
 
-    def filter(self, follow=None, track=None, is_async=False, locations=None,
+    def filter(self, follow=None, track=None, threaded=False, locations=None,
                stall_warnings=False, languages=None, encoding='utf8', filter_level=None):
         body = {}
         self.session.headers['Content-type'] = "application/x-www-form-urlencoded"
@@ -284,7 +284,7 @@ class Stream:
         if filter_level:
             body['filter_level'] = filter_level.encode(encoding)
         self.session.params = {}
-        self._start(is_async, body=body)
+        self._start(threaded, body=body)
 
     def disconnect(self):
         self.running = False