// Copyright (c) 2016, 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 Stream errors
///   Returns a broadcast stream of uncaught errors from the isolate.
///   Each error is provided as an error event on the stream.
///   The actual error object and stackTraces will not necessarily be the same
/// object types as in the actual isolate, but they will always have the same
/// Object.toString result.
///   This stream is based on addErrorListener and removeErrorListener.
///
/// @description Check that each error in isolate is provided as an error event
/// on the errors stream
///
/// @author a.semenov@unipro.ru

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

test() async {
  // setup
  ErrorServer server = await ErrorServer.spawn(errorsAreFatal:false);
  List receivedErrors = [];
  StreamSubscription ss1 = server.isolate.errors.listen(
    (data) { receivedErrors.add(data); },
    onError: (e) { receivedErrors.add(e); }
  );
  // produce errors
  for (int i=0; i<3; i++) {
    server.generateError();
  }
  // clean up
  await server.stop();
  ss1.cancel();
  // check results
  Expect.equals(3, receivedErrors.length);
  asyncEnd();
}

main() {
  asyncStart();
  test();
}