moved close sse http session call to sync manager class

Author: Bilal Al

splitio/client/factory.py

@@ -372,10 +372,6 @@ def __init__(  # pylint: disable=too-many-arguments
 
     async def _update_status_when_ready_async(self):
         """Wait until the sdk is ready and update the status for async mode."""
-        if self._preforked_initialization:
-            self._status = Status.WAITING_FORK
-            return
-
         if self._manager_start_task is not None:
             await self._manager_start_task
             self._manager_start_task = None
@@ -448,9 +444,6 @@ async def destroy(self, destroyed_event=None):
                 if isinstance(self._sync_manager, ManagerAsync) and isinstance(self._telemetry_submitter, InMemoryTelemetrySubmitterAsync):
                     await self._api_client.close_session()
 
-                if isinstance(self._sync_manager, ManagerAsync) and self._sync_manager._streaming_enabled:
-                    await self._sync_manager.close_sse_http_client()
-
         except Exception as e:
             _LOGGER.error('Exception destroying factory.')
             _LOGGER.debug(str(e))

splitio/sync/manager.py

@@ -203,12 +203,10 @@ async def stop(self, blocking):
             self._push_status_handler_active = False
             await self._queue.put(self._CENTINEL_EVENT)
             await self._push.stop(blocking)
+            await self._push.close_sse_http_client()
         await self._synchronizer.shutdown(blocking)
         self._stopped = True
 
-    async def close_sse_http_client(self):
-        await self._push.close_sse_http_client()
-
     async def _streaming_feedback_handler(self):
         """
         Handle status updates from the streaming subsystem.