From 0e0f502402648afee2adb8c10e3205d95ad0d017 Mon Sep 17 00:00:00 2001
From: ggivo <ivo.gaydazhiev@redis.com>
Date: Wed, 18 Dec 2024 11:31:27 +0200
Subject: [PATCH] StreamingCredentialsProvider replaced with
 RedisCredentialsProvider.supportsStreaming()

---
 .../authx/TokenBasedRedisCredentialsProvider.java        | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/main/java/io/lettuce/authx/TokenBasedRedisCredentialsProvider.java b/src/main/java/io/lettuce/authx/TokenBasedRedisCredentialsProvider.java
index 4753010ca..e75abbf23 100644
--- 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>