Add file watching to pub serve.

sdk/lib/_internal/pub/test/serve/utils.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS d.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 pub_tests;
 
 import 'dart:async';
 
 import 'package:http/http.dart' as http;
 import 'package:scheduled_test/scheduled_process.dart';
@@ skipping 49 matching lines @@
 }
 
 /// Schedules an HTTP request to the running pub server with [urlPath] and
 /// verifies that it responds with a 404.
 void requestShould404(String urlPath) {
   schedule(() {
     return http.get("http://localhost:$_port/$urlPath").then((response) {
       expect(response.statusCode, equals(404));
     });
   }, "request $urlPath");
+}
+
+/// Reads lines from pub serve's stdout until one equal to [output] is found.
+///
+/// The schedule will not proceed until the desired output is found. If not
+/// found, it will eventually time out.
+void waitForOutput(String output) {
+  findMatchingLine() {
+    return _pubServer.nextLine().then((line) {
+      if (line == output) return true;
+
+      // This line wasn't it, so ignore it and keep trying.
+      return findMatchingLine();
+    });
+  }
+
+  expect(findMatchingLine(), completion(isTrue));
+}
+
+/// Schedules pumping the event queue.
+void pumpEventQueue() {
+  schedule(() => _pumpEventQueue());
+}
+
+/// 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=20]) {
+  if (times == 0) return new Future.value();
+  // We use a delayed future to allow runAsync events to finish. The
+  // Future.value or Future() constructors use runAsync themselves and would
+  // therefore not wait for runAsync callbacks that are scheduled after invoking
+  // this method.
+  return new Future.delayed(Duration.ZERO, () => _pumpEventQueue(times - 1));
 }