StreamingCredentialsProvider replaced with RedisCredentialsProvider.s…

…upportsStreaming()
redis · Dec 18, 2024 · 0e0f502 · 0e0f502
1 parent 00de1ce
commit 0e0f502
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/io/lettuce/authx/TokenBasedRedisCredentialsProvider.java b/src/main/java/io/lettuce/authx/TokenBasedRedisCredentialsProvider.java
@@ -1,7 +1,7 @@
 package io.lettuce.authx;
 
 import io.lettuce.core.RedisCredentials;
-import io.lettuce.core.StreamingCredentialsProvider;
+import io.lettuce.core.RedisCredentialsProvider;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.core.publisher.Sinks;
@@ -10,7 +10,7 @@
 import redis.clients.authentication.core.TokenListener;
 import redis.clients.authentication.core.TokenManager;
 
-public class TokenBasedRedisCredentialsProvider implements StreamingCredentialsProvider, AutoCloseable {
+public class TokenBasedRedisCredentialsProvider implements RedisCredentialsProvider, AutoCloseable {
 
     private final TokenManager tokenManager;
 
@@ -88,6 +88,11 @@ public Flux<RedisCredentials> credentials() {
         return credentialsSink.asFlux().onBackpressureLatest(); // Provide a continuous stream of credentials
     }
 
+    @Override
+    public boolean supportsStreaming() {
+        return true;
+    }
+
     /**
      * Stop the credentials provider and clean up resources.
      * <p>