main.dart

import 'dart:async';

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

void main() {
  test('', () async {
    // broadcast取ると、expectはtrueになる
    // BehaviorSubjectでも、expectはtrueになる
    final controller = StreamController<bool>.broadcast();
    // 一瞬後にtrueにしてclose
    unawaited(
      Future.microtask(
        () => controller
          ..add(true)
          ..close(),
      ),
    );
    // concatEagerにすると、expectはtrueになる(上でaddしたtrueが捕捉される)
    final v = await Rx.concat([
      Stream.value(false),
      // concatだと、購読直前に上でaddしたtrueが先に流れてしまい捕捉されない
      controller.stream,
    ]).last;

    expect(
      v,
      false, // concatEager・mergeだとtrue
    );
  });
}