From 3f8a09f2b3af517e59a7c90a4717cd35c8ddf08c Mon Sep 17 00:00:00 2001
From: Plague Fox <plugfox@gmail.com>
Date: Thu, 23 May 2024 15:17:51 +0400
Subject: [PATCH] chore: Refactor ChatRepositorySpinifyImpl to use lazy loading
 for event streams

---
 .../feature/chat/data/chat_repository.dart    |  4 +--
 lib/src/model/channel_events.dart             | 27 +++++++++++--------
 2 files changed, 18 insertions(+), 13 deletions(-)

diff --git a/example/lib/src/feature/chat/data/chat_repository.dart b/example/lib/src/feature/chat/data/chat_repository.dart
index c078d64..2a8b1bc 100644
--- a/example/lib/src/feature/chat/data/chat_repository.dart
+++ b/example/lib/src/feature/chat/data/chat_repository.dart
@@ -62,8 +62,8 @@ final class ChatRepositorySpinifyImpl implements IChatRepository {
       decoder = const PlainMessageDecoder();
     }
 
-    return _spinify.stream.publications
-        .where((event) => event.channel == channel)
+    return _spinify.stream
+        .publication(channel: channel)
         .map<List<int>>((event) => event.data)
         .map<Message>(decoder.convert)
         .handleError(ignoreErrors);
diff --git a/lib/src/model/channel_events.dart b/lib/src/model/channel_events.dart
index a8ee835..9d4f2a1 100644
--- a/lib/src/model/channel_events.dart
+++ b/lib/src/model/channel_events.dart
@@ -11,31 +11,36 @@ import 'channel_event.dart';
 extension type ChannelEvents<T extends SpinifyChannelEvent>(Stream<T> stream)
     implements Stream<T> {
   /// Stream of publication events.
-  ChannelEvents<SpinifyPublication> get publication =>
-      filter<SpinifyPublication>();
+  ChannelEvents<SpinifyPublication> publication({String? channel}) =>
+      filter<SpinifyPublication>(channel: channel);
 
   /// Stream of presence events.
-  ChannelEvents<SpinifyPresence> get presence => filter<SpinifyPresence>();
+  ChannelEvents<SpinifyPresence> presence({String? channel}) =>
+      filter<SpinifyPresence>(channel: channel);
 
   /// Stream of unsubscribe events.
-  ChannelEvents<SpinifyUnsubscribe> get unsubscribe =>
-      filter<SpinifyUnsubscribe>();
+  ChannelEvents<SpinifyUnsubscribe> unsubscribe({String? channel}) =>
+      filter<SpinifyUnsubscribe>(channel: channel);
 
   /// Stream of message events.
-  ChannelEvents<SpinifyMessage> get message => filter<SpinifyMessage>();
+  ChannelEvents<SpinifyMessage> message({String? channel}) =>
+      filter<SpinifyMessage>(channel: channel);
 
   /// Stream of subscribe events.
-  ChannelEvents<SpinifySubscribe> get subscribe => filter<SpinifySubscribe>();
+  ChannelEvents<SpinifySubscribe> subscribe({String? channel}) =>
+      filter<SpinifySubscribe>(channel: channel);
 
   /// Stream of connect events.
-  ChannelEvents<SpinifyConnect> get connect => filter<SpinifyConnect>();
+  ChannelEvents<SpinifyConnect> connect({String? channel}) =>
+      filter<SpinifyConnect>(channel: channel);
 
   /// Stream of disconnect events.
-  ChannelEvents<SpinifyDisconnect> get disconnect =>
-      filter<SpinifyDisconnect>();
+  ChannelEvents<SpinifyDisconnect> disconnect({String? channel}) =>
+      filter<SpinifyDisconnect>(channel: channel);
 
   /// Stream of refresh events.
-  ChannelEvents<SpinifyRefresh> get refresh => filter<SpinifyRefresh>();
+  ChannelEvents<SpinifyRefresh> refresh({String? channel}) =>
+      filter<SpinifyRefresh>(channel: channel);
 
   /// Filtered stream of data of [SpinifyChannelEvent].
   ChannelEvents<S> filter<S extends SpinifyChannelEvent>({String? channel}) =>