Add placeholder subsriber

PlugFox · Aug 12, 2023 · 9a13562 · 9a13562
1 parent ab7270c
commit 9a13562
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/example/lib/src/feature/chat/data/chat_repository.dart b/example/lib/src/feature/chat/data/chat_repository.dart
@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:l/l.dart';
 import 'package:spinify/spinify.dart';
 import 'package:spinifyapp/src/feature/authentication/model/user.dart';
 import 'package:spinifyapp/src/feature/chat/controller/chat_connection_state.dart';
@@ -26,7 +27,12 @@ abstract interface class IChatRepository {
 }
 
 final class ChatRepositorySpinifyImpl implements IChatRepository {
-  ChatRepositorySpinifyImpl({required Spinify spinify}) : _spinify = spinify;
+  ChatRepositorySpinifyImpl({required Spinify spinify}) : _spinify = spinify {
+    // TODO(plugfox): remove
+    spinify.stream.publications.listen((event) {
+      l.s('publications: ${const PlainMessageDecoder().convert(event.data).text} ');
+    }, cancelOnError: false);
+  }
 
   /// Centrifugo client
   final Spinify _spinify;

diff --git a/example/lib/src/feature/chat/widget/chat_room.dart b/example/lib/src/feature/chat/widget/chat_room.dart
@@ -135,7 +135,7 @@ class _ChatRoomState extends State<ChatRoom> {
                                 onPressed: enabled
                                     ? () => _messagesController.sendMessage(
                                           widget.user,
-                                          'Hello World',
+                                          value.text,
                                         )
                                     : null,
                               );