fis_lib_jsonrpc/lib/notifications/handler.dart

import 'package:fis_jsonrpc/services/notification.m.dart';
import 'package:flutter/foundation.dart';

import 'core/interface/handler.dart';

abstract class NotificationHandler<T>
    implements IHandler<T>, IDistributable<T> {
  final Set<ValueChanged<T>> _distributeCbList = {};

  /// 通知类型枚举
  final NotificationTypeEnum type;

  NotificationHandler(this.type);

  @override
  int get typeInt => type.index;

  @override
  @protected
  @mustCallSuper
  void execute(T message) {
    if (_distributeCbList.isNotEmpty) {
      for (final cb in _distributeCbList) {
        cb.call(message);
      }
    }
  }

  @override
  void subscribe(ValueChanged<T> callback) {
    _distributeCbList.add(callback);
  }

  @override
  void unsubscribe(ValueChanged<T> callback) {
    _distributeCbList.remove(callback);
  }
}