important exceptions.

Replication status on the source cluster will be marked as `COMPLETED` only after replication is completed on all targets. If one or more targets failed replication, the replication status is reflected as `PENDING`.

        TestResponseProcessor processor2 = new TestResponseProcessor();
        testRule.setRuleId("changedId");
        testRule.setResponseProcessor(processor2);

        // Verify changes are reflected (same object reference)
        assertEquals("changedId", registeredRule.getRuleId());
        assertSame(processor2, registeredRule.getResponseProcessor());
    }

    /**
     * Test inheritance behavior

        override fun checkServerTrusted(
          chain: Array<out X509Certificate>?,
          authType: String?,
        ) {
          withoutHostCalled = true
        }

        // called by Android via reflection in X509TrustManagerExtensions
        @Suppress("unused", "UNUSED_PARAMETER")
        fun checkServerTrusted(
          chain: Array<out X509Certificate>,
          authType: String,
          hostname: String,

    return ImmutableSetMultimap.<String, Integer>builder()
        .put("foo", 1)
        .put("bar", 2)
        .put("foo", 3)
        .build();
  }

  @J2ktIncompatible
  @GwtIncompatible // reflection
  public void testNulls() throws Exception {
    NullPointerTester tester = new NullPointerTester();
    tester.testAllPublicStaticMethods(ImmutableSetMultimap.class);

    }

    @Test
    @DisplayName("Test size method with input buffer")
    void testSizeWithInputBuffer() {
        request = new Smb2QueryInfoRequest(mockConfig);

        // Set an input buffer using reflection
        Encodable mockInputBuffer = mock(Encodable.class);
        when(mockInputBuffer.size()).thenReturn(100);

        try {

    TypeVariableImpl<D> typeVariableImpl = new TypeVariableImpl<>(genericDeclaration, name, bounds);
    @SuppressWarnings("unchecked")
    TypeVariable<D> typeVariable =
        Reflection.newProxy(
            TypeVariable.class, new TypeVariableInvocationHandler(typeVariableImpl));
    return typeVariable;
  }

  /**

## Replica Modification sync

        assertThrows(NullPointerException.class, () -> raf.writeChars(null));
        assertThrows(NullPointerException.class, () -> raf.writeUTF(null));
    }

    // Small reflection helpers to access private fields for interaction verification
    private static Object getField(Object target, String name) {
        try {
            var f = target.getClass().getDeclaredField(name);

    private NullsBeforeTwo() {
      super("two"); // from TestStringSortedMapGenerator's sample keys
    }
  }

  @J2ktIncompatible
  @GwtIncompatible // reflection
  public static Method getMethod(Class<?> clazz, String name) {
    try {
      return clazz.getMethod(name);
    } catch (Exception e) {
      throw new IllegalArgumentException(e);
    }
  }

  public void testPartition_view() {
    List<Integer> list = asList(1, 2);
    Iterator<List<Integer>> partitions = Iterators.partition(list.iterator(), 1);

    // Changes before the partition is retrieved are reflected
    list.set(0, 3);
    List<Integer> first = partitions.next();

    // Changes after are not
    list.set(0, 4);

    assertEquals(ImmutableList.of(3), first);
  }