fluffychat/lib/pangea/common/controllers/base_controller.dart

import 'dart:async';

class BaseController<T> {
  final StreamController<T> _stateListener = StreamController<T>();
  late Stream<T> stateStream;

  BaseController() {
    stateStream = _stateListener.stream.asBroadcastStream();
  }

  dispose() {
    _stateListener.close();
  }

  setState(T data) {
    _stateListener.add(data);
  }
}