StreamBuilder 不监听/更新

Question

我有一个小部件，它有一个public流。在另一个小部件中，我想根据流的数据更新我的 UI。所以我StreamBuilder像往常一样用 a 包裹了流。

在这种情况下，StreamBuilder不会更新，但我可以看到print输出。

我的代码是这样的（原来的代码比较复杂）：

class WidgetA extends StatefulWidget {
  final _WidgetAState _state = _WidgetAState();

  Stream<String> get stream => _state?._subject?.stream;

  @override
  _WidgetAState createState() => _state;
}

class _WidgetAState extends State<WidgetA> {
  final BehaviorSubject<String> _subject = BehaviorSubject<String>();

  @override
  Widget build(BuildContext context) {
    return Container(
      child: FlatButton(
        child: const Text('click'),
        onPressed: () => _subject.add(DateTime.now().toString()),
      ),
    );
  }

  @override
  void dispose() {
    _subject.close();
    super.dispose();
  }
}

class WidgetB extends StatelessWidget {
  @override
  Widget build(BuildContext context) {
    final WidgetA widgetA = WidgetA();
    widgetA.stream.listen((value) => print('value: $value'));

    return Column(
      children: <Widget>[
        widgetA,
        StreamBuilder<Object>(
          stream: widgetA.stream,
          builder: (_, snapshot) => Text('data: ${snapshot.data}'),
        ),
      ],
    );
  }
}

当我stream用另一个包装时stream，它起作用了。

class WidgetB extends StatefulWidget {
  @override
  _WidgetBState createState() => _WidgetBState();
}

class _WidgetBState extends State<WidgetB> {
  final WidgetBBloc bloc = WidgetBBloc();

  @override
  Widget build(BuildContext context) {
    final WidgetA widgetA = WidgetA();
    bloc.init(stream: widgetA.stream);
    bloc.stream.listen((value) => print('value: $value'));

    return Column(
      children: <Widget>[
        widgetA,
        StreamBuilder<Object>(
          stream: bloc.stream,
          builder: (_, snapshot) => Text('data: ${snapshot.data}'),
        ),
      ],
    );
  }
}

class WidgetBBloc {
  Stream<String> get stream => _subject.stream;
  final BehaviorSubject<String> _subject = BehaviorSubject<String>();

  void init({@required Stream<String> stream}) {
    assert(stream != null);
    stream.listen((String s) => _subject.add(s));
  }

  void dispose() {
    _subject.close();
  }
}

为什么StreamBuilder第一个版本的不更新？