@Override
    public void add(long timestamp, V value) {
        addAll(Collections.singletonMap(timestamp, value));
    }
@Test
    public void testCleanup() throws InterruptedException {
        RTimeSeries<String, Object> t = redisson.getTimeSeries("test");
        t.add(1, "10", 1, TimeUnit.SECONDS);

        Thread.sleep(6000);

        assertThat(redisson.getKeys().count()).isZero();
    }