More tweaks in attempt to debug the reason of failing getNavigation() tests.

pkg/analysis_server/test/mocks.dart

 // Copyright (c) 2014, 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 mocks;
 
 import 'dart:async';
 import 'dart:io';
 @MirrorsUsed(targets: 'mocks', override: '*')
 import 'dart:mirrors';
@@ skipping 40 matching lines @@
  * A [Matcher] that check that the given [Response] has an expected identifier
  * and no error.
  */
 Matcher isResponseSuccess(String id) => new _IsResponseSuccess(id);
 
 /**
  * Returns a [Future] that completes after pumping the event queue [times]
  * 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 will hide the problem, but...

   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
   // would therefore not wait for microtask callbacks that are scheduled after
   // invoking this method.
   return new Future.delayed(Duration.ZERO, () => pumpEventQueue(times - 1));
 }
 
 typedef void MockServerOperationPerformFunction(AnalysisServer server);
 
@@ skipping 150 matching lines @@
   }
 
   void expectMsgCount({responseCount: 0, notificationCount: 0}) {
     expect(responsesReceived, hasLength(responseCount));
     expect(notificationsReceived, hasLength(notificationCount));
   }
 
   @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
   void sendNotification(Notification notification) {
     // Don't deliver notifications after the connection is closed.
     if (_closed) {
       return;
     }
     notificationsReceived.add(notification);
     // Wrap send notification in future to simulate websocket
@@ skipping 79 matching lines @@
   void add(T text) => controller.add(text);
 
   void allowMultipleListeners() {
     stream = stream.asBroadcastStream();
   }
 
   Future close([int code, String reason]) =>
       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);
 
   Stream<T> where(bool test(T)) => stream.where(test);
 }
 
 class MockSource extends StringTypedMock implements Source {
   MockSource([String name = 'mocked.dart']) : super(name);
   noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
@@ skipping 116 matching lines @@
     }
     return mismatchDescription;
   }
 
   @override
   bool matches(item, Map matchState) {
     Response response = item;
     return response != null && response.id == _id && response.error == null;
   }
 }