Default AsyncBaseStream to abort closed SSL transports

Resolves #1904
tweepy · Oct 29, 2022 · 1aa5d39 · 1aa5d39
1 parent 51a5d61
commit 1aa5d39
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/tweepy/asynchronous/streaming.py b/tweepy/asynchronous/streaming.py
@@ -53,6 +53,7 @@ async def _connect(
 
         if self.session is None or self.session.closed:
             self.session = aiohttp.ClientSession(
+                connector=aiohttp.TCPConnector(enable_cleanup_closed=True),
                 timeout=aiohttp.ClientTimeout(sock_read=timeout)
             )
         self.session.headers["User-Agent"] = self.user_agent