adding blocs for conversation related

lib/src/blocs/contact_bloc.dart

@@ -1,4 +1,5 @@
 import "package:rxdart/rxdart.dart";
+
 import "../resources/repository.dart";
 import "../models/user_model.dart";
 

lib/src/blocs/conversation_bloc.dart

@@ -0,0 +1,43 @@
+import "package:rxdart/rxdart.dart";
+
+import "../resources/repository.dart";
+import "../models/user_model.dart";
+import "../models/conversation_model.dart";
+
+class ConversationsBloc {
+  final _repository = Repository();
+  final _conversationsFetcher = PublishSubject<List<Conversation>>();
+
+  Observable<List<Conversation>> get conversations =>
+      _conversationsFetcher.stream;
+
+  fetchConversations() async {
+    List<Conversation> conversationList =
+        await _repository.fetchConversations();
+    _conversationsFetcher.sink.add(conversationList);
+  }
+
+  dispose() {
+    _conversationsFetcher.close();
+  }
+}
+
+class ConversationMembersBloc {
+  final String conversationId;
+  final _repository = Repository();
+  final _membersFetcher = PublishSubject<List<User>>();
+
+  ConversationMembersBloc(this.conversationId);
+
+  Observable<List<User>> get members => _membersFetcher.stream;
+
+  fetchMembers() async {
+    List<User> memberList =
+        await _repository.fetchConversationMembers(conversationId);
+    _membersFetcher.sink.add(memberList);
+  }
+
+  dispose() {
+    _membersFetcher.close();
+  }
+}