sealed class BaseEvent implements DomainEvent {
  factory BaseEvent.added() = Added;

  factory BaseEvent.removed() = Removed;
}

class Added implements BaseEvent {}

class Removed implements BaseEvent {}

void checkEvent<TEvent extends BaseEvent>(String name, BaseEvent event) {
  print('$name handler');
  print('TEvent: $TEvent');
  print('Instance: ${event.runtimeType}');
}

extension on EventManager {
  Future<void> dispatchBaseEvent(BaseEvent event) => dispatch(event);
}

Future<void> main() async {
  final mediator = Mediator.create();

  mediator.events.on<Added>().subscribeFunction((e) => checkEvent('added', e));
  mediator.events
      .on<Removed>()
      .subscribeFunction((e) => checkEvent('removed', e));
  mediator.events
      .on<BaseEvent>()
      .subscribeFunction((e) => checkEvent('base', e));

  await mediator.events.dispatchBaseEvent(BaseEvent.added());
  await mediator.events.dispatchBaseEvent(BaseEvent.removed());
}