Update TweepError calls to TweepyException

The Error module was updated to TweepyException and needs to be reflected in the async stream.

diff --git a/tweepy/asynchronous/__init__.py b/tweepy/asynchronous/__init__.py
index bc1200a2cf8d4f288ac90e41aee523641aaffbd1..aac29bb9e4a6ad70c4fca2180708527b7e6239ec 100644 (file)
--- a/tweepy/asynchronous/__init__.py
+++ b/tweepy/asynchronous/__init__.py
@@ -11,7 +11,7 @@ Asynchronous interfaces with the Twitter API
 try:
     import aiohttp
 except ModuleNotFoundError:
-    from tweepy.error import TweepError
-    raise TweepError("tweepy.asynchronous requires aiohttp to be installed")
+    from tweepy.errors import TweepyException
+    raise TweepyException("tweepy.asynchronous requires aiohttp to be installed")
 
 from tweepy.asynchronous.streaming import AsyncStream

diff --git a/tweepy/asynchronous/streaming.py b/tweepy/asynchronous/streaming.py
index c5a1a376cb60d0ac94c633e7d1966a547f60b2e8..da3c04c01827bbb9102b846b00dfa9d4e82472ba 100644 (file)
--- a/tweepy/asynchronous/streaming.py
+++ b/tweepy/asynchronous/streaming.py
@@ -13,7 +13,7 @@ from oauthlib.oauth1 import Client as OAuthClient
 from yarl import URL
 
 import tweepy
-from tweepy.error import TweepError
+from tweepy.errors import TweepyException
 from tweepy.models import Status
 
 log = logging.getLogger(__name__)
@@ -165,7 +165,7 @@ class AsyncStream:
         Returns :class:`asyncio.Task`
         """
         if self.task is not None and not self.task.done():
-            raise TweepError("Stream is already connected")
+            raise TweepyException("Stream is already connected")
 
         endpoint = "statuses/filter"
         headers = {"Content-Type": "application/x-www-form-urlencoded"}
@@ -177,7 +177,7 @@ class AsyncStream:
             body["track"] = ','.join(map(str, track))
         if locations is not None:
             if len(locations) % 4:
-                raise TweepError(
+                raise TweepyException(
                     "Number of location coordinates should be a multiple of 4"
                 )
             body["locations"] = ','.join(
@@ -207,7 +207,7 @@ class AsyncStream:
         Returns :class:`asyncio.Task`
         """
         if self.task is not None and not self.task.done():
-            raise TweepError("Stream is already connected")
+            raise TweepyException("Stream is already connected")
 
         endpoint = "statuses/sample"