rxdart行为主题散发出以前的事件，不仅是最后一个值

Question

我对rxdart 。 通常，行为主体只能散发出流的最后值：

一种特殊的streamController捕获已添加到控制器的最新项目，并将其作为任何新侦听器的第一项。

但是在我的情况下，它也在流中排出所有以前的值，我不知道为什么。

我有以下测试集合：

class TestBloc {

  final _controller = BehaviorSubject.seeded([]);

  Stream get stream$ => _controller.stream;

  TestBloc(BehaviorSubject subject) {
    subject.listen((e) {
      print("listen $e");
      _controller.add([e]);
    });
  }

}

带测试案例：

    test("test bloc", () async {
      final subject = BehaviorSubject();

      final bloc = TestBloc(subject);

      subject.add(1);
      subject.add(2);

      // Uncomment next line to make test pass
      // await expectLater(subject.stream, emits(2)); 

      // Test will fail here
      await expectLater(bloc.stream$, emits([2]));
    });

测试失败，因为从主题发出的所有事件发出，而不仅是预期的最后：

Expected: should emit an event that [2]
  Actual: <Instance of 'BehaviorSubject<List<dynamic>>'>
   Which: emitted * []
                  * [1]
                  * [2]
            which emitted an event that at location [0] is [] which shorter than expected

这是rxdart的问题，还是我做错了什么。 要我理解.add（）在侦听器中呼叫的效果应与在测试用例中添加连续添加的效果相同，但似乎并非如此。

Answer 1

代码精神

当与流并发时，相同的行为可能会面临。
为了说明这一点，您可以在代码中添加夫妇调试行：

class TestBloc {

  final _controller = BehaviorSubject.seeded([]);

  Stream get stream$ => _controller.stream;

  TestBloc(BehaviorSubject subject) {
    subject.listen((e) {
      print("listen $e");
      print('A: ${DateTime.now()}');
      _controller.add([e]);
      print('B: ${DateTime.now()}');
    });
  }

}

测试案例：

test("test bloc", () async {
      final subject = BehaviorSubject();

      final bloc = TestBloc(subject);

      subject.add(1);
      subject.add(2);

      // Uncomment next line to make test pass
      // await expectLater(subject.stream, emits(2));

      /// If you uncomment next comment it will fix the problem
      /// this await Future.delayed(Duration.zero) is added
      /// to avoid executing the expectLater() before
      /// the listener in TestBloc constructor.

      // await Future.delayed(Duration.zero);
      print('C: ${DateTime.now()}');
      await expectLater(bloc.stream$, emits([2]));
      print('D: ${DateTime.now()}');
  });

如果运行此代码，则会看到：

C: 2022-08-24 23:52:23.910217
listen 1
A: 2022-08-24 23:52:23.941463
B: 2022-08-24 23:52:23.942454
listen 2
A: 2022-08-24 23:52:23.945855
B: 2022-08-24 23:52:23.946078

因此

await expectLater(bloc.stream$, emits([2]));

已执行以前执行

_controller.add([e]);

，但是当您的删节时

await expectLater(subject.stream, emits(2));

，它的角色与

await Future.delayed(Duration.zero);

Answer 2

因此，如果您期望最后一项Willbe [2]，则必须将[2]作为预期值推动。如果您需要收听多个值，也可以推动多个值

测试（“ test Bloc”，（）async {
最终主题=行为主题（）;

  final bloc = TestBloc(subject);

  subject.add(2);

  // Test will successful
  await expectLater(bloc.stream$, emits([2]));
});