public Single<Boolean> addAll(Publisher<? extends V> c) {
        return new PublisherAdder<V>() {

            @Override
            public RFuture<Boolean> add(Object o) {
                return instance.addAsync((V) o);
            }

        }.addAll(c);
    }
@Test
    public void testAddAllWithIndex() throws InterruptedException {
        final RListRx<Long> list = redisson.getList("list");
        final CountDownLatch latch = new CountDownLatch(1);
        list.addAll(Arrays.asList(1L, 2L, 3L)).subscribe((Boolean element, Throwable error) -> {
            if (error != null) {
                Assertions.fail(error.getMessage());
                return;
            }
            
            list.addAll(Arrays.asList(1L, 24L, 3L)).subscribe((Boolean value, Throwable err) -> {
                if (err != null) {
                    Assertions.fail(err.getMessage());
                    return;
                }
                
                latch.countDown();
            });
        });

        latch.await();

        assertThat(sync(list)).containsExactly(1L, 2L, 3L, 1L, 24L, 3L);
    }