diff --git a/faststream/redis/subscriber/specified.py b/faststream/redis/subscriber/specified.py index ffc14121d7..4598cfd987 100644 --- a/faststream/redis/subscriber/specified.py +++ b/faststream/redis/subscriber/specified.py @@ -113,7 +113,7 @@ class SpecificationConcurrentSubscriber( class SpecificationStreamConcurrentSubscriber( - ConcurrentStreamSubscriber, _StreamSubscriberMixin + ConcurrentStreamSubscriber, SpecificationStreamSubscriber ): pass @@ -125,6 +125,6 @@ class SpecificationChannelConcurrentSubscriber( class SpecificationListConcurrentSubscriber( - ConcurrentListSubscriber, _ListSubscriberMixin + ConcurrentListSubscriber, SpecificationListSubscriber ): pass