| OLD | NEW |
| 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2015, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library unittest.test.utils; | 5 library unittest.test.utils; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:collection'; | 8 import 'dart:collection'; |
| 9 import 'dart:io'; |
| 10 |
| 11 import 'package:path/path.dart' as p; |
| 12 import 'package:stack_trace/stack_trace.dart'; |
| 9 | 13 |
| 10 import 'package:unittest/src/live_test.dart'; | 14 import 'package:unittest/src/live_test.dart'; |
| 11 import 'package:unittest/src/remote_exception.dart'; | 15 import 'package:unittest/src/remote_exception.dart'; |
| 12 import 'package:unittest/src/state.dart'; | 16 import 'package:unittest/src/state.dart'; |
| 13 import 'package:unittest/unittest.dart'; | 17 import 'package:unittest/unittest.dart'; |
| 14 | 18 |
| 15 // The last state change detected via [expectStates]. | 19 // The last state change detected via [expectStates]. |
| 16 State lastState; | 20 State lastState; |
| 17 | 21 |
| 22 final String packageDir = _computePackageDir(); |
| 23 |
| 24 String _computePackageDir() { |
| 25 var trace = new Trace.current(); |
| 26 return p.dirname(p.dirname(p.fromUri(trace.frames.first.uri))); |
| 27 } |
| 28 |
| 18 /// Asserts that exactly [states] will be emitted via [liveTest.onStateChange]. | 29 /// Asserts that exactly [states] will be emitted via [liveTest.onStateChange]. |
| 19 /// | 30 /// |
| 20 /// The most recent emitted state is stored in [_lastState]. | 31 /// The most recent emitted state is stored in [_lastState]. |
| 21 void expectStates(LiveTest liveTest, Iterable<State> statesIter) { | 32 void expectStates(LiveTest liveTest, Iterable<State> statesIter) { |
| 22 var states = new Queue.from(statesIter); | 33 var states = new Queue.from(statesIter); |
| 23 liveTest.onStateChange.listen(expectAsync((state) { | 34 liveTest.onStateChange.listen(expectAsync((state) { |
| 24 lastState = state; | 35 lastState = state; |
| 25 expect(state, equals(states.removeFirst())); | 36 expect(state, equals(states.removeFirst())); |
| 26 }, count: states.length, max: states.length)); | 37 }, count: states.length, max: states.length)); |
| 27 } | 38 } |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 64 /// Returns a matcher that matches a [TestFailure] with the given [message]. | 75 /// Returns a matcher that matches a [TestFailure] with the given [message]. |
| 65 Matcher isTestFailure(String message) => predicate( | 76 Matcher isTestFailure(String message) => predicate( |
| 66 (error) => error is TestFailure && error.message == message, | 77 (error) => error is TestFailure && error.message == message, |
| 67 'is a TestFailure with message "$message"'); | 78 'is a TestFailure with message "$message"'); |
| 68 | 79 |
| 69 /// Returns a matcher that matches a [RemoteException] with the given [message]. | 80 /// Returns a matcher that matches a [RemoteException] with the given [message]. |
| 70 Matcher isRemoteException(String message) => predicate( | 81 Matcher isRemoteException(String message) => predicate( |
| 71 (error) => error is RemoteException && error.message == message, | 82 (error) => error is RemoteException && error.message == message, |
| 72 'is a RemoteException with message "$message"'); | 83 'is a RemoteException with message "$message"'); |
| 73 | 84 |
| 85 /// Returns a matcher that matches a [FileSystemException] with the given |
| 86 /// [message]. |
| 87 Matcher isFileSystemException(String message) => predicate( |
| 88 (error) => error is FileSystemException && error.message == message, |
| 89 'is a FileSystemException with message "$message"'); |
| 90 |
| 74 /// Returns a [Future] that completes after pumping the event queue [times] | 91 /// Returns a [Future] that completes after pumping the event queue [times] |
| 75 /// times. | 92 /// times. |
| 76 /// | 93 /// |
| 77 /// By default, this should pump the event queue enough times to allow any code | 94 /// By default, this should pump the event queue enough times to allow any code |
| 78 /// to run, as long as it's not waiting on some external event. | 95 /// to run, as long as it's not waiting on some external event. |
| 79 Future pumpEventQueue([int times=20]) { | 96 Future pumpEventQueue([int times=20]) { |
| 80 if (times == 0) return new Future.value(); | 97 if (times == 0) return new Future.value(); |
| 81 // Use [new Future] future to allow microtask events to finish. The [new | 98 // Use [new Future] future to allow microtask events to finish. The [new |
| 82 // Future.value] constructor uses scheduleMicrotask itself and would therefore | 99 // Future.value] constructor uses scheduleMicrotask itself and would therefore |
| 83 // not wait for microtask callbacks that are scheduled after invoking this | 100 // not wait for microtask callbacks that are scheduled after invoking this |
| 84 // method. | 101 // method. |
| 85 return new Future(() => pumpEventQueue(times - 1)); | 102 return new Future(() => pumpEventQueue(times - 1)); |
| 86 } | 103 } |
| OLD | NEW |