

def __init__(self, client):
    self._pending = {
        
    }
    self._event_handlers = {
        
    }
    self._next_correlation_id = AtomicInteger(1)
    self._client = client
    self._event_queue = Queue()
    client._is_redo_operation = client.config.network_config.redo_operation
    if client.config.network_config.smart_routing:
        self.invoke = self.invoke_smart
    else:
        self.invoke = self.invoke_non_smart
    self._client.connection_manager.add_listener(on_connection_closed=self.cleanup_connection)
    client.heartbeat.add_listener(on_heartbeat_stopped=self._heartbeat_stopped)

dataset/ETHPy150Open hazelcast/hazelcast-python-client/hazelcast/invocation.py InvocationService.__init__/VarMisuse@53/66 `self`->`client`