frontend_flutter/lib/src/blocs/conversation_bloc.dart

import "package:rxdart/rxdart.dart";

import "../resources/conversation_api_provider.dart";
import "../models/user_model.dart";
import "../models/conversation_model.dart";

class ConversationsBloc {
  final _provider = ConversationApiProvider();
  final _conversationsFetcher = PublishSubject<List<Conversation>>();

  Observable<List<Conversation>> get conversations =>
      _conversationsFetcher.stream;

  fetchConversations() async {
    List<Conversation> conversationList = await _provider.fetchConversations();
    print(conversationList);
    _conversationsFetcher.sink.add(conversationList);
  }

  dispose() {
    _conversationsFetcher.close();
  }
}

// Should be a scoped widget
class ConversationMembersBloc {
  final String conversationId;
  final _provider = ConversationApiProvider();
  final _membersFetcher = PublishSubject<List<User>>();

  ConversationMembersBloc(this.conversationId);

  Observable<List<User>> get members => _membersFetcher.stream;

  fetchMembers() async {
    List<User> memberList =
        await _provider.fetchConversationMembers(conversationId);
    _membersFetcher.sink.add(memberList);
  }

  dispose() {
    _membersFetcher.close();
  }
}

final conversationsBloc = ConversationsBloc();