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 |