beep
/
frontend_flutter
4
2
Fork 0
Code Issues 14 Pull Requests 4 Releases Activity

Merge branch 'fix/removes-resource-class' of beep/frontend_flutter into master

pull/41/head^2
Sudharshan S. 2019-03-23 13:24:28 +00:00 committed by Gitea
parent 2e64ead6f6 da37fd3785
commit f1cf08f810
3 changed files with 8 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/src/blocs/contact_bloc.dart
View File

@ -1,17 +1,17 @@
import "package:rxdart/rxdart.dart";
import "../resources/repository.dart";
import "../resources/contact_api_provider.dart";
import "../models/user_model.dart";
// TODO: SHOULD BE A INHERITED SCOPED BLOC Widget
class ContactBloc {
final _repository = Repository();
final _provider = ContactApiProvider();
final _contactsFetcher = PublishSubject<List<User>>();
Observable<List<User>> get contacts => _contactsFetcher.stream;
fetchContacts() async {
List<User> contactList = await _repository.fetchContacts();
List<User> contactList = await _provider.fetchContacts();
_contactsFetcher.sink.add(contactList);
}

11
lib/src/blocs/conversation_bloc.dart
View File

@ -1,19 +1,18 @@
import "package:rxdart/rxdart.dart";
import "../resources/repository.dart";
import "../resources/conversation_api_provider.dart";
import "../models/user_model.dart";
import "../models/conversation_model.dart";
class ConversationsBloc {
final _repository = Repository();
final _provider = ConversationApiProvider();
final _conversationsFetcher = PublishSubject<List<Conversation>>();
Observable<List<Conversation>> get conversations =>
_conversationsFetcher.stream;
fetchConversations() async {
List<Conversation> conversationList =
await _repository.fetchConversations();
List<Conversation> conversationList = await _provider.fetchConversations();
_conversationsFetcher.sink.add(conversationList);
}
@ -24,7 +23,7 @@ class ConversationsBloc {
class ConversationMembersBloc {
final String conversationId;
final _repository = Repository();
final _provider = ConversationApiProvider();
final _membersFetcher = PublishSubject<List<User>>();
ConversationMembersBloc(this.conversationId);
@ -33,7 +32,7 @@ class ConversationMembersBloc {
fetchMembers() async {
List<User> memberList =
await _repository.fetchConversationMembers(conversationId);
await _provider.fetchConversationMembers(conversationId);
_membersFetcher.sink.add(memberList);
}

20
lib/src/resources/repository.dart
View File

@ -1,20 +0,0 @@
import "dart:async";
import "contact_api_provider.dart";
import "conversation_api_provider.dart";
import "../models/user_model.dart";
import "../models/conversation_model.dart";
class Repository {
final contactApiProvider = ContactApiProvider();
final conversationApiProvider = ConversationApiProvider();
Future<List<User>> fetchContacts() => contactApiProvider.fetchContacts();
Future<List<Conversation>> fetchConversations() =>
conversationApiProvider.fetchConversations();
Future<List<User>> fetchConversationMembers(String id) =>
conversationApiProvider.fetchConversationMembers(id);
}