behavior_subject.dart

import 'package:rxdart/rxdart.dart';
import 'package:test/test.dart';

void main() {
  test('BehaviorSubjectのサンプル', () {
    BehaviorSubject<int> subject = new BehaviorSubject<int>();

    // 1, 2をStreamに流す。しかしこの時点ではListenerがいないので配信されない
    subject.sink.add(1);
    subject.sink.add(2);

    // 1, 2は流れてしまった後に、Listenerを追加。最後の要素の2を受け取ることができる
    subject.listen(expectAsync1((int data) {
      expect(data, 2);
    }));

    // さらに別のListenerも追加。Broadcastなので、こちらでも受信できる
    subject.listen(expectAsync1((int data) {
      expect(data, 2);
    }));
  });
}