Fix AsyncStream reuse

diff --git a/tweepy/asynchronous/streaming.py b/tweepy/asynchronous/streaming.py
index 39b391332a0e142cea3e31d4c5a597fd97341ddd..7433cf635f7c5ab98aee461f57ce3e1a93761042 100644 (file)
--- a/tweepy/asynchronous/streaming.py
+++ b/tweepy/asynchronous/streaming.py
@@ -170,7 +170,7 @@ class AsyncStream:
 
         Returns :class:`asyncio.Task`
         """
-        if self.task is not None:
+        if self.task is not None and not self.task.done():
             raise TweepError('Stream is already connected')
 
         endpoint = "statuses/filter"
@@ -212,7 +212,7 @@ class AsyncStream:
 
         Returns :class:`asyncio.Task`
         """
-        if self.task is not None:
+        if self.task is not None and not self.task.done():
             raise TweepError("Stream is already connected")
 
         endpoint = "statuses/sample"