publish_subject.dart

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

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

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

    // 1, 2は流れてしまった後に、Listenerを追加
    subject.listen(expectAsync1((int data) {
      expect(data, 3);
    }));

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

    // 3をStreamに流す。ここで初めて、上記のListenerが呼ばれる
    subject.sink.add(3);
  });
}