anchor.diff:        // ignore: unawaited_futures
         () async {
           for (int i = 0; i < 10 * 60; i++) {
  -          if (observatoryLines.isNotEmpty) break;
  +          if (leakTest == null || leakTest.observatoryLines.isNotEmpty) {
  +            break;
  +          }
             await Future.delayed(new Duration(seconds: 1));
           }
   
  
positive.code:   // ignore: unawaited_futures
    process.exitCode.then((int exitCode) {
      stopwatch.stop();
      print("$id finished in ${stopwatch.elapsed.toString()}");
    });
    return new WrappedProcess(process, id);
  }
  
  class WrappedProcess {
    final Process process;
    final String id;
  
    WrappedProcess(this.process, this.id);
  }
  
negative.code:     } else {
        // The tools/bots/flutter/compile_flutter.sh script passes `--path`
        // --- we'll just pass everything along.
        leakTest = await run(
          [
            leakTester.toString(),
            ...args,
          ],
          "leak test",
        );
        startedProcesses.add(leakTest);
      }
    }
    {
  