pkgs/stream_transform/test/scan_test.dart

import 'dart:async';

import 'package:test/test.dart';

import 'package:stream_transform/stream_transform.dart';

void main() {
  group('Scan', () {
    test('produces intermediate values', () async {
      var source = new Stream.fromIterable([1, 2, 3, 4]);
      var sum = (int x, int y) => x + y;
      var result = await source.transform(scan(0, sum)).toList();

      expect(result, [1, 3, 6, 10]);
    });

    test('can create a broadcast stream', () async {
      var source = new StreamController.broadcast();

      var transformed = source.stream.transform(scan(null, null));

      expect(transformed.isBroadcast, true);
    });
  });
}