| Index: packages/stack_trace/test/chain/utils.dart
|
| diff --git a/packages/stack_trace/test/chain/utils.dart b/packages/stack_trace/test/chain/utils.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..1e19eeb3c64de393f843020c8f7e06ce479c0f05
|
| --- /dev/null
|
| +++ b/packages/stack_trace/test/chain/utils.dart
|
| @@ -0,0 +1,93 @@
|
| +// Copyright (c) 2015, 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.
|
| +
|
| +library stack_trace.test.chain.utils;
|
| +
|
| +import 'dart:async';
|
| +
|
| +import 'package:stack_trace/stack_trace.dart';
|
| +import 'package:test/test.dart';
|
| +
|
| +/// Runs [callback] in a microtask callback.
|
| +void inMicrotask(callback()) => scheduleMicrotask(callback);
|
| +
|
| +/// Runs [callback] in a one-shot timer callback.
|
| +void inOneShotTimer(callback()) => Timer.run(callback);
|
| +
|
| +/// Runs [callback] once in a periodic timer callback.
|
| +void inPeriodicTimer(callback()) {
|
| + var count = 0;
|
| + new Timer.periodic(new Duration(milliseconds: 1), (timer) {
|
| + count++;
|
| + if (count != 5) return;
|
| + timer.cancel();
|
| + callback();
|
| + });
|
| +}
|
| +
|
| +/// Runs [callback] within a long asynchronous Future chain.
|
| +void inFutureChain(callback()) {
|
| + new Future(() {})
|
| + .then((_) => new Future(() {}))
|
| + .then((_) => new Future(() {}))
|
| + .then((_) => new Future(() {}))
|
| + .then((_) => new Future(() {}))
|
| + .then((_) => callback())
|
| + .then((_) => new Future(() {}));
|
| +}
|
| +
|
| +void inNewFuture(callback()) {
|
| + new Future(callback);
|
| +}
|
| +
|
| +void inSyncFuture(callback()) {
|
| + new Future.sync(callback);
|
| +}
|
| +
|
| +/// Returns a Future that completes to an error using a completer.
|
| +///
|
| +/// If [trace] is passed, it's used as the stack trace for the error.
|
| +Future completerErrorFuture([StackTrace trace]) {
|
| + var completer = new Completer();
|
| + completer.completeError('error', trace);
|
| + return completer.future;
|
| +}
|
| +
|
| +/// Returns a Stream that emits an error using a controller.
|
| +///
|
| +/// If [trace] is passed, it's used as the stack trace for the error.
|
| +Stream controllerErrorStream([StackTrace trace]) {
|
| + var controller = new StreamController();
|
| + controller.addError('error', trace);
|
| + return controller.stream;
|
| +}
|
| +
|
| +/// Runs [callback] within [asyncFn], then converts any errors raised into a
|
| +/// [Chain] with [Chain.forTrace].
|
| +Future<Chain> chainForTrace(asyncFn(callback()), callback()) {
|
| + var completer = new Completer();
|
| + asyncFn(() {
|
| + // We use `new Future.value().then(...)` here as opposed to [new Future] or
|
| + // [new Future.sync] because those methods don't pass the exception through
|
| + // the zone specification before propagating it, so there's no chance to
|
| + // attach a chain to its stack trace. See issue 15105.
|
| + new Future.value().then((_) => callback())
|
| + .catchError(completer.completeError);
|
| + });
|
| + return completer.future
|
| + .catchError((_, stackTrace) => new Chain.forTrace(stackTrace));
|
| +}
|
| +
|
| +/// Runs [callback] in a [Chain.capture] zone and returns a Future that
|
| +/// completes to the stack chain for an error thrown by [callback].
|
| +///
|
| +/// [callback] is expected to throw the string `"error"`.
|
| +Future<Chain> captureFuture(callback()) {
|
| + var completer = new Completer<Chain>();
|
| + Chain.capture(callback, onError: (error, chain) {
|
| + expect(error, equals('error'));
|
| + completer.complete(chain);
|
| + });
|
| + return completer.future;
|
| +}
|
|
|