|
|
|
@ -5,8 +5,7 @@ import java.util.Collections;
|
|
|
|
|
import java.util.Iterator;
|
|
|
|
|
import java.util.concurrent.CountDownLatch;
|
|
|
|
|
|
|
|
|
|
import org.hamcrest.MatcherAssert;
|
|
|
|
|
import org.hamcrest.Matchers;
|
|
|
|
|
import static org.assertj.core.api.Assertions.*;
|
|
|
|
|
import org.junit.Assert;
|
|
|
|
|
import org.junit.Test;
|
|
|
|
|
import org.redisson.api.RListReactive;
|
|
|
|
@ -53,7 +52,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
sync(test2.add("foo"));
|
|
|
|
|
sync(test2.add(0, "bar"));
|
|
|
|
|
|
|
|
|
|
MatcherAssert.assertThat(sync(test2), Matchers.contains("bar", "foo"));
|
|
|
|
|
assertThat(sync(test2)).containsExactly("bar", "foo");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -99,7 +98,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
|
|
|
|
|
latch.await();
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1L, 2L, 3L, 1L, 24L, 3L));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1L, 2L, 3L, 1L, 24L, 3L);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -130,7 +129,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
|
|
|
|
|
latch.await();
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1L, 2L));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1L, 2L);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -139,7 +138,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
sync(list.add(1L));
|
|
|
|
|
sync(list.add(2L));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1L, 2L));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1L, 2L);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -291,7 +290,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
Integer val = sync(list.remove(0));
|
|
|
|
|
Assert.assertTrue(1 == val);
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(2, 3, 4, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(2, 3, 4, 5);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -305,7 +304,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
|
|
|
|
|
sync(list.set(4, 6));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 2, 3, 4, 6));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2, 3, 4, 6);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test(expected = RedisException.class)
|
|
|
|
@ -345,11 +344,11 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
Assert.assertFalse(sync(list.removeAll(Collections.emptyList())));
|
|
|
|
|
Assert.assertTrue(sync(list.removeAll(Arrays.asList(3, 2, 10, 6))));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 4, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 4, 5);
|
|
|
|
|
|
|
|
|
|
Assert.assertTrue(sync(list.removeAll(Arrays.asList(4))));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 5);
|
|
|
|
|
|
|
|
|
|
Assert.assertTrue(sync(list.removeAll(Arrays.asList(1, 5, 1, 5))));
|
|
|
|
|
|
|
|
|
@ -367,7 +366,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
|
|
|
|
|
Assert.assertTrue(sync(list.retainAll(Arrays.asList(3, 2, 10, 6))));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(2, 3));
|
|
|
|
|
assertThat(sync(list)).containsExactly(2, 3);
|
|
|
|
|
Assert.assertEquals(2, sync(list.size()).longValue());
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -401,7 +400,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
sync(list.add(2));
|
|
|
|
|
|
|
|
|
|
Assert.assertFalse(sync(list.retainAll(Arrays.asList(1, 2)))); // nothing changed
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 2));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test(expected = RedisException.class)
|
|
|
|
@ -421,19 +420,19 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
|
|
|
|
|
Assert.assertEquals(8, sync(list.addAll(2, Arrays.asList(7, 8, 9))).longValue());
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 2, 7, 8, 9, 3, 4, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2, 7, 8, 9, 3, 4, 5);
|
|
|
|
|
|
|
|
|
|
sync(list.addAll(sync(list.size())-1, Arrays.asList(9, 1, 9)));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 2, 7, 8, 9, 3, 4, 9, 1, 9, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2, 7, 8, 9, 3, 4, 9, 1, 9, 5);
|
|
|
|
|
|
|
|
|
|
sync(list.addAll(sync(list.size()), Arrays.asList(0, 5)));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 2, 7, 8, 9, 3, 4, 9, 1, 9, 5, 0, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2, 7, 8, 9, 3, 4, 9, 1, 9, 5, 0, 5);
|
|
|
|
|
|
|
|
|
|
Assert.assertEquals(15, sync(list.addAll(0, Arrays.asList(6, 7))).intValue());
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(6,7,1, 2, 7, 8, 9, 3, 4, 9, 1, 9, 5, 0, 5));
|
|
|
|
|
assertThat(sync(list)).containsExactly(6,7,1, 2, 7, 8, 9, 3, 4, 9, 1, 9, 5, 0, 5);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -449,7 +448,7 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
|
|
|
|
|
Assert.assertEquals(11, sync(list.addAll(Arrays.asList(9, 1, 9))).intValue());
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains(1, 2, 3, 4, 5, 7, 8, 9, 9, 1, 9));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2, 3, 4, 5, 7, 8, 9, 9, 1, 9);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -569,13 +568,13 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
sync(list.add("4"));
|
|
|
|
|
sync(list.add("5"));
|
|
|
|
|
sync(list.add("6"));
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains("1", "2", "3", "4", "5", "6"));
|
|
|
|
|
assertThat(sync(list)).containsExactly("1", "2", "3", "4", "5", "6");
|
|
|
|
|
|
|
|
|
|
sync(list.remove("2"));
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains("1", "3", "4", "5", "6"));
|
|
|
|
|
assertThat(sync(list)).containsExactly("1", "3", "4", "5", "6");
|
|
|
|
|
|
|
|
|
|
sync(list.remove("4"));
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.contains("1", "3", "5", "6"));
|
|
|
|
|
assertThat(sync(list)).containsExactly("1", "3", "5", "6");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Test
|
|
|
|
@ -586,6 +585,6 @@ public class RedissonListReactiveTest extends BaseReactiveTest {
|
|
|
|
|
sync(list.add("3"));
|
|
|
|
|
sync(list.add("e"));
|
|
|
|
|
|
|
|
|
|
Assert.assertThat(sync(list), Matchers.<Object>contains(1, 2L, "3", "e"));
|
|
|
|
|
assertThat(sync(list)).containsExactly(1, 2L, "3", "e");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|