Chromium Code Reviews| Index: pkg/analysis_server/test/mocks.dart |
| diff --git a/pkg/analysis_server/test/mocks.dart b/pkg/analysis_server/test/mocks.dart |
| index 3358b475840219bb57e90828d28a36053c28b8e3..1ce0d9fe87d403b5bc7e5aee7eefd5ca319c0850 100644 |
| --- a/pkg/analysis_server/test/mocks.dart |
| +++ b/pkg/analysis_server/test/mocks.dart |
| @@ -58,7 +58,7 @@ Matcher isResponseSuccess(String id) => new _IsResponseSuccess(id); |
| * times. By default, this should pump the event queue enough times to allow |
| * any code to run, as long as it's not waiting on some external event. |
| */ |
| -Future pumpEventQueue([int times = 500]) { |
| +Future pumpEventQueue([int times = 5000]) { |
|
Brian Wilkerson
2015/08/11 18:13:01
I'm a little concerned that changing the limit wil
|
| if (times == 0) return new Future.value(); |
| // We use a delayed future to allow microtask events to finish. The |
| // Future.value or Future() constructors use scheduleMicrotask themselves and |
| @@ -229,8 +229,8 @@ class MockServerChannel implements ServerCommunicationChannel { |
| @override |
| void listen(void onRequest(Request request), |
| {Function onError, void onDone()}) { |
| - requestController.stream.listen(onRequest, |
| - onError: onError, onDone: onDone); |
| + requestController.stream |
| + .listen(onRequest, onError: onError, onDone: onDone); |
| } |
| @override |
| @@ -330,8 +330,8 @@ class MockSocket<T> implements WebSocket { |
| controller.close().then((_) => twin.controller.close()); |
| StreamSubscription<T> listen(void onData(T event), |
| - {Function onError, void onDone(), bool cancelOnError}) => stream.listen( |
| - onData, |
| + {Function onError, void onDone(), bool cancelOnError}) => |
| + stream.listen(onData, |
| onError: onError, onDone: onDone, cancelOnError: cancelOnError); |
| noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation); |