Initial implementation for 'analysis.setSubscriptions' API.

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: '*')
@@ skipping 123 matching lines @@
 
   @override
   void listen(void onRequest(Request request), {Function onError, void onDone()}) {
     requestController.stream.listen(onRequest, onError: onError, onDone: onDone);
   }
 
   @override
   void sendNotification(Notification notification) {
     notificationsReceived.add(notification);
     // Wrap send notification in future to simulate websocket
-    new Future(() => notificationController.add(notification));
+    // TODO(scheglov) ask Dan why and decide what to do
+//    new Future(() => notificationController.add(notification));
+    notificationController.add(notification);
   }
 
   /**
    * Simulate request/response pair.
    */
   Future<Response> sendRequest(Request request) {
     var id = request.id;
     // Wrap send request in future to simulate websocket
     new Future(() => requestController.add(request));
     pumpEventQueue().then((_) => responseController.addError(
@@ skipping 139 matching lines @@
     Response response = item;
     var id = response.id;
     RequestError error = response.error;
     mismatchDescription.add('has identifier "$id"');
     if (error == null) {
       mismatchDescription.add(' and has no error');
     }
     return mismatchDescription;
   }
 }