From f821ff0146c8a40af1f18d4637ae28d5e2665bab Mon Sep 17 00:00:00 2001
From: Nikita Koksharov <nkoksharov@redisson.pro>
Date: Fri, 24 Nov 2023 11:10:37 +0300
Subject: [PATCH] tests fixed

---
 .../RedissonBaseMultimapCacheTest.java        |  2 +-
 ...dissonTransactionalBucketReactiveTest.java | 22 +++++++++++++------
 2 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/redisson/src/test/java/org/redisson/RedissonBaseMultimapCacheTest.java b/redisson/src/test/java/org/redisson/RedissonBaseMultimapCacheTest.java
index dd9e1ce00..0bcc7ab0b 100644
--- a/redisson/src/test/java/org/redisson/RedissonBaseMultimapCacheTest.java
+++ b/redisson/src/test/java/org/redisson/RedissonBaseMultimapCacheTest.java
@@ -122,7 +122,7 @@ public abstract class RedissonBaseMultimapCacheTest extends RedisDockerTest {
         
         assertThat(cache.size()).isEqualTo(6);
         
-        Thread.sleep(10000);
+        Thread.sleep(12000);
 
         assertThat(cache.size()).isZero();
 
diff --git a/redisson/src/test/java/org/redisson/transaction/RedissonTransactionalBucketReactiveTest.java b/redisson/src/test/java/org/redisson/transaction/RedissonTransactionalBucketReactiveTest.java
index 0bfa7b3b1..5e0c4788a 100644
--- a/redisson/src/test/java/org/redisson/transaction/RedissonTransactionalBucketReactiveTest.java
+++ b/redisson/src/test/java/org/redisson/transaction/RedissonTransactionalBucketReactiveTest.java
@@ -73,7 +73,7 @@ public class RedissonTransactionalBucketReactiveTest extends BaseReactiveTest {
     }
     
     @Test
-    public void testGetAndSet() {
+    public void testGetAndSet() throws InterruptedException {
         RBucketReactive<String> b = redisson.getBucket("test");
         sync(b.set("123"));
         
@@ -84,13 +84,15 @@ public class RedissonTransactionalBucketReactiveTest extends BaseReactiveTest {
         assertThat(sync(bucket.getAndSet("324"))).isEqualTo("0");
         
         sync(transaction.commit());
-        
+
+        Thread.sleep(100);
+
         assertThat(sync(redisson.getKeys().count())).isEqualTo(1);
         assertThat(sync(b.get())).isEqualTo("324");
     }
     
     @Test
-    public void testCompareAndSet() {
+    public void testCompareAndSet() throws InterruptedException {
         RBucketReactive<String> b = redisson.getBucket("test");
         sync(b.set("123"));
         
@@ -102,13 +104,15 @@ public class RedissonTransactionalBucketReactiveTest extends BaseReactiveTest {
         assertThat(sync(bucket.get())).isEqualTo("232");
         
         sync(transaction.commit());
+
+        Thread.sleep(100);
         
         assertThat(sync(redisson.getKeys().count())).isEqualTo(1);
         assertThat(sync(b.get())).isEqualTo("232");
     }
     
     @Test
-    public void testTrySet() {
+    public void testTrySet() throws InterruptedException {
         RBucketReactive<String> b = redisson.getBucket("test");
         sync(b.set("123"));
         
@@ -120,13 +124,15 @@ public class RedissonTransactionalBucketReactiveTest extends BaseReactiveTest {
         assertThat(sync(bucket.trySet("43"))).isFalse();
         
         sync(transaction.commit());
-        
+
+        Thread.sleep(100);
+
         assertThat(sync(redisson.getKeys().count())).isEqualTo(1);
         assertThat(sync(b.get())).isEqualTo("324");
     }
     
     @Test
-    public void testGetAndRemove() {
+    public void testGetAndRemove() throws InterruptedException {
         RBucketReactive<String> m = redisson.getBucket("test");
         sync(m.set("123"));
         
@@ -140,7 +146,9 @@ public class RedissonTransactionalBucketReactiveTest extends BaseReactiveTest {
         assertThat(sync(set.getAndDelete())).isNull();
         
         sync(transaction.commit());
-        
+
+        Thread.sleep(100);
+
         assertThat(sync(redisson.getKeys().count())).isEqualTo(0);
         assertThat(sync(m.get())).isNull();
     }