LocalORSetTest.java 文件源码

@Test
public void shouldSynchronizeConcurrentAddsOfSameElement() {
    // given:
    final String element = "Hello World";
    replica2.disconnect(replica3);

    // when:
    orSet1.add(element);
    orSet3.add(element);

    // then:
    assertThat(orSet1, contains(element));
    assertThat(orSet2, equalTo(orSet1));
    assertThat(orSet3, equalTo(orSet1));

    // when:
    replica2.connect(replica3);

    // then:
    assertThat(orSet1, contains(element));
    assertThat(orSet2, equalTo(orSet1));
    assertThat(orSet3, equalTo(orSet1));
}