为什么当我添加第二个侦听器时此广播流不起作用

Question

我不明白为什么这个广播流不起作用。

我正在将数据从 _auth.onAuthStateChanged 发送到一个新的 StreamController，以便我可以更好地控制流。

下面的代码可以正常工作，但是一旦我取消注释 _userStream.listen(_handleUserStream); 行，流就会停止工作，即使 userStream 是广播流。

我尝试将 StreamController 初始化为 StreamController.broadcast()，但即使只有一个侦听器，它也根本不起作用。

class AuthService() {
  final FirebaseAuth _auth = FirebaseAuth.instance;

  StreamController<FirebaseUser> _userStreamController;
  Stream<User> _userStream;
  Stream<User> get userStream => _userStream;


  AuthService() {
    initStream();
  }

  initStream() async {
    _userStreamController = StreamController<FirebaseUser>();
    _userStream = _userStreamController.stream
        .asBroadcastStream()
        .asyncMap(_userFromFirebaseUser);

    _auth.onAuthStateChanged.listen((event) {
      _userStreamController.add(event);
    });

    // _userStream.listen(_handleUserStream);
  }

  ... other methods
}

Answer 1

你可以在initStream的第一行直接将streamController初始化为广播流，然后就可以直接使用该流了，如下图

class AuthService() {
  final FirebaseAuth _auth = FirebaseAuth.instance;

  StreamController<FirebaseUser> _userStreamController;
  Stream<User> _userStream;
  Stream<User> get userStream => _userStream;


  AuthService() {
    initStream();
  }

  initStream() async {
    _userStreamController = StreamController.broadcast();
    _userStream = _userStreamController.stream;

    _userStream.listen(_handleUserStream);

    _auth.onAuthStateChanged.listen((event) {
      _userStreamController.add(event);
    });
  }

  ... other methods
}