Feat: replace subscribers (#1976)

* Feat: replace subscribers * Fix: lint * Fix: add mixin * Fix: lint * Fix: add markers * chore: fix tests --------- Co-authored-by: Daniil Dumchenko <[email protected]> Co-authored-by: Pastukhov Nikita <[email protected]> Co-authored-by: Nikita Pastukhov <[email protected]>
airtai · Dec 10, 2024 · b9c7dd4 · b9c7dd4
1 parent 5f4c9f4
commit b9c7dd4
Show file tree

Hide file tree

Showing 8 changed files with 896 additions and 779 deletions.
diff --git a/faststream/redis/subscriber/specified.py b/faststream/redis/subscriber/specified.py
@@ -3,10 +3,14 @@
 )
 from faststream.redis.schemas import ListSub, StreamSub
 from faststream.redis.schemas.proto import RedisSpecificationProtocol
-from faststream.redis.subscriber.usecase import (
-    BatchListSubscriber,
+from faststream.redis.subscriber.usecases.channel_subscriber import (
     ChannelSubscriber,
+)
+from faststream.redis.subscriber.usecases.list_subscriber import (
+    BatchListSubscriber,
     ListSubscriber,
+)
+from faststream.redis.subscriber.usecases.stream_subscriber import (
     StreamBatchSubscriber,
     StreamSubscriber,
 )