LibTest/async/StreamController/addStream_A03_t02.dart

// Copyright (c) 2011, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

/// @assertion Future addStream(Stream<T> source, {bool cancelOnError: true})
/// If cancelOnError is true, only the first error on source is forwarded to
/// the controller's stream, and the addStream ends after this.
/// If cancelOnError is false, all errors are forwarded and only a done event
/// will end the addStream.
///
/// @description Checks that if cancelOnError is false, all error events of
/// source are added to the controller's stream and only done event ends the
/// addStream.
/// @author ilya

import "dart:async";
import "../../../Utils/expect.dart";

listen(Stream stream, List expectedData, List expectedErrors) {
  List actualData = [];
  List actualErrors = [];

  stream.listen((x) {
    actualData.add(x);
  }, onError: (x) {
    actualErrors.add(x);
  }, onDone: () {
    Expect.listEquals(expectedData, actualData);
    Expect.listEquals(expectedErrors, actualErrors);
    asyncEnd();
  });
}

// new stream, negative data become errors
Stream toDataErrorStream(Stream stream) =>
    stream.map((x) => x < 0 ? throw x : x);

main() {
  StreamController c = new StreamController();
  List iterable = [1, 2, 3, -1, -2, -3, 4, 5, 6];
  Stream s = toDataErrorStream(new Stream.fromIterable(iterable));

  asyncStart(2);
  listen(c.stream, [1, 2, 3, 4, 5, 6], [-1, -2, -3]);
  c.addStream(s, cancelOnError: false).then((_) {
    c.close();
    asyncEnd();
  });
}