@@ -8,13 +8,14 @@ import datadog.trace.api.DDSpanTypes
8
8
import datadog.trace.bootstrap.instrumentation.api.Tags
9
9
import io.lettuce.core.ClientOptions
10
10
import io.lettuce.core.RedisClient
11
- import io.lettuce.core.api.StatefulConnection
11
+ import io.lettuce.core.api.StatefulRedisConnection
12
12
import io.lettuce.core.api.reactive.RedisReactiveCommands
13
13
import io.lettuce.core.api.sync.RedisCommands
14
14
import org.testcontainers.containers.wait.strategy.Wait
15
15
import reactor.core.scheduler.Schedulers
16
16
import spock.lang.Shared
17
17
import spock.util.concurrent.AsyncConditions
18
+ import spock.util.concurrent.PollingConditions
18
19
19
20
import java.util.function.Consumer
20
21
@@ -40,7 +41,7 @@ abstract class Lettuce5ReactiveClientTest extends VersionedNamingTestBase {
40
41
.waitingFor(Wait . forListeningPort())
41
42
42
43
RedisClient redisClient
43
- StatefulConnection connection
44
+ StatefulRedisConnection connection
44
45
RedisReactiveCommands<String , ?> reactiveCommands
45
46
RedisCommands<String , ?> syncCommands
46
47
@@ -54,7 +55,9 @@ abstract class Lettuce5ReactiveClientTest extends VersionedNamingTestBase {
54
55
55
56
redisClient. setOptions(CLIENT_OPTIONS )
56
57
57
- connection = redisClient. connect()
58
+ new PollingConditions (delay : 3 , timeout : 15 ). eventually {
59
+ (connection = redisClient. connect()) != null
60
+ }
58
61
reactiveCommands = connection. reactive()
59
62
syncCommands = connection. sync()
60
63
0 commit comments