Added StreamingCredentialProvider interface

redis/credentials.py

@@ -1,4 +1,5 @@
-from typing import Optional, Tuple, Union
+from abc import ABC, abstractmethod
+from typing import Optional, Tuple, Union, Callable, Any
 
 
 class CredentialProvider:
@@ -10,6 +11,17 @@ def get_credentials(self) -> Union[Tuple[str], Tuple[str, str]]:
         raise NotImplementedError("get_credentials must be implemented")
 
 
+class StreamingCredentialProvider(CredentialProvider, ABC):
+    @abstractmethod
+    def on_next(self, callback: Callable[[Any], None]):
+        pass
+
+    @abstractmethod
+    def is_streaming(self) -> bool:
+        pass
+
+
+
 class UsernamePasswordCredentialProvider(CredentialProvider):
     """
     Simple implementation of CredentialProvider that just wraps static