HashMultimap<String, Integer> copy = HashMultimap.create(multimap);
    assertEquals(multimap, copy);
    assertEquals(2, copy.expectedValuesPerKey);
  }

  public void testCreateFromSizes() {
    HashMultimap<String, Integer> multimap = HashMultimap.create(20, 15);
    multimap.put("foo", 1);
    multimap.put("bar", 2);
    multimap.put("foo", 3);
    assertEquals(ImmutableSet.of(1, 3), multimap.get("foo"));

  public void testIsEmpty() throws IOException {
    assertEquals(expected.isEmpty(), source.isEmpty());
  }

  public void testLength() throws IOException {
    assertEquals(expected.length(), source.length());
  }

  public void testLengthIfKnown() throws IOException {
    Optional<Long> lengthIfKnown = source.lengthIfKnown();
    if (lengthIfKnown.isPresent()) {
      assertEquals(expected.length(), (long) lengthIfKnown.get());

        // Verify that the handle passed to the constructor is correctly set in the superclass
        assertEquals(mockHandle, lsarClose.handle, "The handle should be initialized correctly.");

        // Verify that the ptype is set to 0
        assertEquals(0, lsarClose.getPtype(), "The ptype should be set to 0.");

        assertNotNull(mockService.getAddress());
        assertTrue(mockService.getPort() > 0);
        assertEquals(0, mockService.getRegistrationCount());

        // Test registration
        String regId = mockService.registerWitness("\\\\server\\share", "192.168.1.100", 1);
        assertNotNull(regId);
        assertEquals(1, mockService.getRegistrationCount());
        assertTrue(mockService.hasRegistration(regId));

    }
  }

  public void testPutIfAbsent() {
    TestMap map = new TestMap();
    map.put("foo", 1);
    assertEquals(Integer.valueOf(1), map.putIfAbsent("foo", 2));
    assertEquals(Integer.valueOf(1), map.get("foo"));
    assertThat(map.putIfAbsent("bar", 3)).isNull();
    assertEquals(Integer.valueOf(3), map.get("bar"));
  }

  public void testRemove() {
    TestMap map = new TestMap();
    map.put("foo", 1);

  }

  @MapFeature.Require(SUPPORTS_REMOVE)
  public void testKeySetRemovePropagatesToMultimap() {
    int key0Count = multimap().get(k0()).size();
    assertEquals(key0Count > 0, multimap().keySet().remove(k0()));
    assertEquals(getNumElements() - key0Count, multimap().size());
    assertGet(k0());
  }

  @CollectionSize.Require(absent = ZERO)
  @CollectionFeature.Require(SUPPORTS_ITERATOR_REMOVE)

        assertTrue("Then callback should complete", latch.await(10, TimeUnit.SECONDS));
        Thread.sleep(100); // Wait a bit to ensure error callback isn't called
        assertEquals("Then callback should be invoked", 1, thenCount.get());
        assertEquals("Error callback should not be invoked", 0, errorCount.get());
    }

    @Test
    public void test_mixedCallbacks_onlyErrorInvokedOnReject() throws Exception {

    int originalCount = getMultiset().count(e0());
    assertEquals("old count", originalCount, getMultiset().add(e0(), 2));
    assertEquals("old count", originalCount + 2, getMultiset().count(e0()));
  }

  @CollectionFeature.Require(SUPPORTS_ADD)
  public void testAddSeveralTimes() {
    int originalCount = getMultiset().count(e0());
    assertEquals(originalCount, getMultiset().add(e0(), 2));

        // equals should match case-insensitively for name and equal OID
        MIEName expected = new MIEName(testOid(), name);
        assertEquals(expected, parsed, "Parsed object should equal expected");
        assertEquals(name, parsed.toString(), "toString should return the name");
        assertEquals(testOid().hashCode(), parsed.hashCode(), "hashCode should derive from OID");
    }

    @Test

        assertNotNull(guid);
        assertEquals(1, manager.getHandleCount());

        HandleInfo info = manager.getHandleByGuid(guid);
        assertNotNull(info);
        assertEquals("/test/file.txt", info.getPath());
        assertEquals(HandleType.DURABLE_V2, info.getType());
        assertEquals(120000, info.getTimeout());
    }

    @Test
    public void testUpdateHandleFileId() {