removed loading anext to push classes

Author: Bilal Al

splitio/optional/loaders.py

@@ -16,8 +16,3 @@ def missing_asyncio_dependencies(*_, **__):
 
 async def _anext(it):
     return await it.__anext__()
-
-if sys.version_info.major == 3 and sys.version_info.minor < 10:
-    anext = _anext
-else:
-    anext = anext

splitio/push/manager.py

@@ -2,7 +2,9 @@
 import logging
 from threading import Timer
 import abc
-from splitio.optional.loaders import asyncio, anext
+import sys
+
+from splitio.optional.loaders import asyncio
 from splitio.api import APIException
 from splitio.util.time import get_current_epoch_time_ms
 from splitio.push import AuthException
@@ -14,6 +16,9 @@
 from splitio.push.status_tracker import PushStatusTracker, Status, PushStatusTrackerAsync
 from splitio.models.telemetry import StreamingEventTypes
 
+if sys.version_info.major == 3 and sys.version_info.minor < 10:
+  from splitio.optional.loaders import _anext as anext
+
 _TOKEN_REFRESH_GRACE_PERIOD = 10 * 60  # 10 minutes
 
 _LOGGER = logging.getLogger(__name__)

splitio/push/splitsse.py

@@ -3,11 +3,15 @@
 import threading
 from enum import Enum
 import abc
+import sys
 
 from splitio.push.sse import SSEClient, SSEClientAsync, SSE_EVENT_ERROR
 from splitio.util.threadutil import EventGroup
 from splitio.api import headers_from_metadata
-from splitio.optional.loaders import anext, asyncio
+from splitio.optional.loaders import asyncio
+
+if sys.version_info.major == 3 and sys.version_info.minor < 10:
+  from splitio.optional.loaders import _anext as anext
 
 _LOGGER = logging.getLogger(__name__)