More strong mode clean-up in server

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';
 
 import 'package:analysis_server/plugin/protocol/protocol.dart'
@@ skipping 234 matching lines @@
     responsesReceived.add(response);
     // Wrap send response in future to simulate WebSocket.
     new Future(() => responseController.add(response));
   }
 
   Future<Response> waitForResponse(Request request) {
     String id = request.id;
     pumpEventQueue().then((_) {
       responseController.addError(new NoResponseException(request));
     });
-    return responseController.stream.firstWhere((response) {
-      return response.id == id;
-    });
+    return new Future<Response>(() =>
+        responseController.stream.firstWhere((response) => response.id == id));
   }
 }
 
 /**
  * A mock [ServerOperation] for testing [AnalysisServer].
  */
 class MockServerOperation implements PerformAnalysisOperation {
   final ServerOperationPriority priority;
   final MockServerOperationPerformFunction _perform;
 
@@ skipping 22 matching lines @@
   factory MockSocket.pair() {
     MockSocket<T> socket1 = new MockSocket<T>();
     MockSocket<T> socket2 = new MockSocket<T>();
     socket1.twin = socket2;
     socket2.twin = socket1;
     socket1.stream = socket2.controller.stream;
     socket2.stream = socket1.controller.stream;
     return socket1;
   }
 
-  void add(T text) => controller.add(text);
+  void add(dynamic text) => controller.add(text as T);
 
   void allowMultipleListeners() {
     stream = stream.asBroadcastStream();
   }
 
   Future close([int code, String reason]) =>
       controller.close().then((_) => twin.controller.close());
 
-  StreamSubscription<T> listen(void onData(T event),
+  StreamSubscription<T> listen(void onData(dynamic event),
           {Function onError, void onDone(), bool cancelOnError}) =>
-      stream.listen(onData,
+      stream.listen((T data) => onData(data),
           onError: onError, onDone: onDone, cancelOnError: cancelOnError);
 
   noSuchMethod(Invocation invocation) => super.noSuchMethod(invocation);
 
-  Stream<T> where(bool test(T t)) => stream.where(test);
+  Stream<T> where(bool test(dynamic t)) => stream.where((T data) => test(data));
 }
 
 class MockSource extends StringTypedMock implements Source {
   MockSource([String name = 'mocked.dart']) : super(name);
 }
 
 class MockTopLevelVariableElement extends TypedMock
     implements TopLevelVariableElement {
   final ElementKind kind = ElementKind.TOP_LEVEL_VARIABLE;
 }
@@ skipping 108 matching lines @@
     }
     return mismatchDescription;
   }
 
   @override
   bool matches(item, Map matchState) {
     Response response = item;
     return response != null && response.id == _id && response.error == null;
   }
 }