Fix more tests for the new task model

pkg/analysis_server/test/analysis_server_test.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 test.analysis_server;
 
 import 'dart:async';
 
 import 'package:analysis_server/src/analysis_server.dart';
 import 'package:analysis_server/src/constants.dart';
@@ skipping 190 matching lines @@
     server.serverServices = [ServerService.STATUS].toSet();
     // Analyze project foo containing foo.dart and project bar containing
     // bar.dart.
     resourceProvider.newFolder('/foo');
     resourceProvider.newFolder('/bar');
     File foo = resourceProvider.newFile('/foo/foo.dart', 'library lib;');
     Source fooSource = foo.createSource();
     File bar = resourceProvider.newFile('/bar/bar.dart', 'library lib;');
     Source barSource = bar.createSource();
     server.setAnalysisRoots('0', ['/foo', '/bar'], [], {});
-    return pumpEventQueue(50).then((_) {
+    return pumpEventQueue(200).then((_) {
       expect(server.statusAnalyzing, isFalse);
       // Make sure getAnalysisContext returns the proper context for each.
       AnalysisContext fooContext =
           server.getAnalysisContextForSource(fooSource);
       expect(fooContext, isNotNull);
       AnalysisContext barContext =
           server.getAnalysisContextForSource(barSource);
       expect(barContext, isNotNull);
       expect(fooContext, isNot(same(barContext)));
       expect(fooContext.getKindOf(fooSource), SourceKind.LIBRARY);
@@ skipping 91 matching lines @@
     resourceProvider.newFolder('/bar');
     resourceProvider.newFile('/foo/foo.dart', 'import "../bar/bar.dart";');
     File bar = resourceProvider.newFile('/bar/bar.dart', 'library bar;');
     server.setAnalysisRoots('0', ['/foo', '/bar'], [], {});
     Map<AnalysisService, Set<String>> subscriptions =
         <AnalysisService, Set<String>>{};
     for (AnalysisService service in AnalysisService.VALUES) {
       subscriptions[service] = <String>[bar.path].toSet();
     }
     server.setAnalysisSubscriptions(subscriptions);
-    await pumpEventQueue(100);
+    await pumpEventQueue(200);
     expect(server.statusAnalyzing, isFalse);
     channel.notificationsReceived.clear();
     server.updateContent(
         '0', {bar.path: new AddContentOverlay('library bar; void f() {}')});
-    await pumpEventQueue(100);
+    await pumpEventQueue(200);
     expect(server.statusAnalyzing, isFalse);
     expect(channel.notificationsReceived, isNotEmpty);
     Set<String> notificationTypesReceived = new Set<String>();
     for (Notification notification in channel.notificationsReceived) {
       String notificationType = notification.event;
       switch (notificationType) {
         case 'server.status':
         case 'analysis.errors':
           // It's normal for these notifications to be sent multiple times.
           break;
@@ skipping 161 matching lines @@
   _MockServerOperation(this.context);
 
   @override
   ServerOperationPriority get priority => ServerOperationPriority.ANALYSIS;
 
   @override
   void perform(AnalysisServer server) {
     isComplete = true;
   }
 }