public Flowable<V> iterator(int count) {
        return iterator(null, count);
    }
@Test
    public void testAddBean() throws InterruptedException, ExecutionException {
        SimpleBean sb = new SimpleBean();
        sb.setLng(1L);
        RSetRx<SimpleBean> set = redisson.getSet("simple");
        sync(set.add(sb));
        Assertions.assertEquals(sb.getLng(), toIterator(set.iterator()).next().getLng());
    }