test fixed

redisson/src/test/java/org/redisson/RedissonStreamTest.java

@@ -178,7 +178,7 @@ public class RedissonStreamTest extends BaseTest {
     }
 
     @Test
-    public void testClaimRemove() {
+    public void testClaimRemove() throws InterruptedException {
         RStream<String, String> stream = redisson.getStream("test");
 
         stream.add(StreamAddArgs.entry("0", "0"));
@@ -199,6 +199,8 @@ public class RedissonStreamTest extends BaseTest {
 
         stream.remove(id3);
 
+        Thread.sleep(2);
+
         Map<StreamMessageId, Map<String, String>> res = stream.claim("testGroup", "consumer1", 1, TimeUnit.MILLISECONDS, id3, id4);
         assertThat(res.size()).isEqualTo(1);
         assertThat(res.keySet()).containsExactly(id4);