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); |