modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/ActiveActorTest.java [232:285]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        var clusterServices = new HashMap<NetworkAddress, ClusterService>();
        var raftServers = new HashMap<NetworkAddress, JraftServerImpl>();
        int nodes = 3;
        Predicate<NetworkAddress> isServerAddress = addr -> true;

        TopologyAwareRaftGroupService raftClient = startCluster(
                testInfo,
                clusterServices,
                raftServers,
                isServerAddress,
                nodes,
                PORT_BASE
        );

        raftClient.refreshLeader().get();

        var clientClusterService = clusterService(testInfo, PORT_BASE + nodes + 1, new StaticNodeFinder(getNetworkAddresses(nodes)));
        clientClusterService.start();

        TopologyAwareRaftGroupService raftClientNoInitialNotify = startTopologyAwareClient(
                clientClusterService,
                clusterServices,
                isServerAddress,
                nodes,
                null,
                false
        );

        AtomicReference<ClusterNode> leaderRef = new AtomicReference<>();
        AtomicReference<ClusterNode> leaderRefNoInitialNotify = new AtomicReference<>();
        AtomicInteger callsCount = new AtomicInteger();

        raftClient.subscribeLeader((node, term) -> leaderRef.set(node));

        for (int i = 0; i < 2; i++) {
            raftClientNoInitialNotify.unsubscribeLeader();

            raftClientNoInitialNotify.subscribeLeader((node, term) -> {
                callsCount.incrementAndGet();
                leaderRefNoInitialNotify.set(node);
            });
        }

        assertTrue(callsCount.get() <= 1);

        assertTrue(waitForCondition(() -> leaderRef.get() != null, 10_000));

        ClusterNode leader = leaderRef.get();

        assertNotNull(leader);

        log.info("Leader: " + leader);

        afterInitCheckConditionWithWait(leader.name());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/ActiveActorTest.java [313:366]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        var clusterServices = new HashMap<NetworkAddress, ClusterService>();
        var raftServers = new HashMap<NetworkAddress, JraftServerImpl>();
        int nodes = 3;
        Predicate<NetworkAddress> isServerAddress = addr -> true;

        TopologyAwareRaftGroupService raftClient = startCluster(
                testInfo,
                clusterServices,
                raftServers,
                isServerAddress,
                nodes,
                PORT_BASE
        );

        raftClient.refreshLeader().get();

        var clientClusterService = clusterService(testInfo, PORT_BASE + nodes + 1, new StaticNodeFinder(getNetworkAddresses(nodes)));
        clientClusterService.start();

        TopologyAwareRaftGroupService raftClientNoInitialNotify = startTopologyAwareClient(
                clientClusterService,
                clusterServices,
                isServerAddress,
                nodes,
                null,
                false
        );

        AtomicReference<ClusterNode> leaderRef = new AtomicReference<>();
        AtomicReference<ClusterNode> leaderRefNoInitialNotify = new AtomicReference<>();
        AtomicInteger callsCount = new AtomicInteger();

        raftClient.subscribeLeader((node, term) -> leaderRef.set(node));

        for (int i = 0; i < 2; i++) {
            raftClientNoInitialNotify.unsubscribeLeader();

            raftClientNoInitialNotify.subscribeLeader((node, term) -> {
                callsCount.incrementAndGet();
                leaderRefNoInitialNotify.set(node);
            });
        }

        assertTrue(callsCount.get() <= 1);

        assertTrue(waitForCondition(() -> leaderRef.get() != null, 10_000));

        ClusterNode leader = leaderRef.get();

        assertNotNull(leader);

        log.info("Leader: " + leader);

        afterInitCheckConditionWithWait(leader.name());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -