Dart如何使用反射包装所有Stream方法实现委托调用

不需要借助反射，也完全不需要手动重写Stream的所有方法，Dart语言特性本身就支持极简实现这个需求。

• Dart 官方反射库dart:mirrors在AOT编译场景（比如Flutter发布构建）下默认被禁用，强行使用会直接导致编译失败，方案通用性极差。
• 反射是运行时动态调用，性能开销远高于原生实现，在Stream高频推送事件的场景下会带来不必要的性能损耗。
• 反射逻辑没有编译期类型校验，方法签名不匹配、参数传错等问题只能在运行时触发，调试成本很高。

Dart的Stream是抽象类，整个Stream接口对外暴露的几十上百个方法（包括map、where、asBroadcastStream、first、toList等），核心只有listen是必须子类实现的抽象方法，其余所有方法都是基类基于listen封装的默认实现。
你只需要重写listen方法，把调用转发给内部持有的目标Stream实例，所有Stream自带方法就会自动走委托逻辑，不需要逐个重写。而你在MyCustomStream里定义的自定义方法，因为子类没有重写，会直接保留父类的原有实现，完全符合你的需求。

首先要修正你原有代码的递归问题：构造函数里直接调用this.asBroadcastStream()会触发循环调用——因为asBroadcastStream最终会调用当前实例的listen方法，而此时内部持有的stream还没完成初始化，会出现空指针或栈溢出。

class MyCustomStream<T> extends Stream<T> {
  // 自定义方法，后续会被StreamWrapper直接继承，保留原有逻辑
  void myCustomMethod() {
    print('执行自定义流逻辑');
  }

  @override
  StreamSubscription<T> listen(
    void Function(T event)? onData, {
    Function? onError,
    void Function()? onDone,
    bool? cancelOnError,
  }) {
    // MyCustomStream自身的订阅逻辑
    // ...
  }
}

class StreamWrapper<T> extends MyCustomStream<T> {
  late final Stream<T> _innerStream;

  StreamWrapper() {
    // 调用父类的asBroadcastStream避免触发重写后的listen，完成内部流初始化
    // 如果是包装外部传入的Stream，直接在这里给_innerStream赋值即可
    _innerStream = super.asBroadcastStream();
  }

  // 仅需重写这一个核心方法，所有Stream自带方法自动完成委托
  @override
  StreamSubscription<T> listen(
    void Function(T event)? onData, {
    Function? onError,
    void Function()? onDone,
    bool? cancelOnError,
  }) {
    return _innerStream.listen(
      onData,
      onError: onError,
      onDone: onDone,
      cancelOnError: cancelOnError,
    );
  }
}

如果有个别Stream方法需要自定义逻辑，不需要全量重写所有方法，只需要单独重写对应方法做特殊处理即可。

内容的提问来源于stack exchange，提问作者SmallJoe