Add async speedups (#44)

Author: ferhatelmas

setup.py

@@ -6,7 +6,7 @@
 install_requires = [
     "pycryptodomex>=3.8.1,<4",
     "requests>=2.22.0,<3",
-    "aiohttp>=3.6",
+    "aiohttp[speedups]>=3.6",
     "aiofile>=3.1,<4",
     "pyjwt==1.7.1",
 ]

stream_chat/tests/async_chat/test_channel.py

@@ -238,17 +238,16 @@ async def test_invites(self, event_loop, client, channel):
             if m["user_id"] == "ringo":
                 assert m["invited"] is True
                 assert "invite_accepted_at" in m
-        # cannot accept again
-        with pytest.raises(StreamAPIException):
-            await channel.accept_invite("ringo")
+        # can accept again, noop
+        await channel.accept_invite("ringo")
+
         reject = await channel.reject_invite("eric")
         for m in reject["members"]:
             if m["user_id"] == "eric":
                 assert m["invited"] is True
                 assert "invite_rejected_at" in m
-        # cannot reject again
-        with pytest.raises(StreamAPIException):
-            reject = await channel.reject_invite("eric")
+        # can reject again, noop
+        await channel.reject_invite("eric")
 
     @pytest.mark.asyncio
     async def test_query_members(self, event_loop, client, channel):

stream_chat/tests/test_channel.py

@@ -213,17 +213,16 @@ def test_invites(self, client, channel):
             if m["user_id"] == "ringo":
                 assert m["invited"] is True
                 assert "invite_accepted_at" in m
-        # cannot accept again
-        with pytest.raises(StreamAPIException):
-            channel.accept_invite("ringo")
+        # can accept again, noop
+        channel.accept_invite("ringo")
+
         reject = channel.reject_invite("eric")
         for m in reject["members"]:
             if m["user_id"] == "eric":
                 assert m["invited"] is True
                 assert "invite_rejected_at" in m
-        # cannot reject again
-        with pytest.raises(StreamAPIException):
-            reject = channel.reject_invite("eric")
+        # cannot reject again, noop
+        channel.reject_invite("eric")
 
     def test_query_members(self, client, channel):
         members = ["paul", "george", "john", "jessica", "john2"]