anchor.diff:  import '../compile.dart';
   import '../dart/package_map.dart';
   import '../globals.dart';
  +import '../vmservice.dart';
   import 'watcher.dart';
   
   /// The timeout we give the test process to connect to the test harness
  
positive.code:     return remoteChannel;
    }
  
    Future<_AsyncError> _startTest(
      String testPath,
      StreamChannel<dynamic> controller,
  
negative.code:             printTrace('test $ourTestCount: using observatory uri $detectedUri from pid ${process.pid}');
            }
            processObservatoryUri = detectedUri;
            {
              printTrace('Connecting to service protocol: $processObservatoryUri');
              final Future<VMService> localVmService = VMService.connect(processObservatoryUri,
                compileExpression: _compileExpressionService);
              localVmService.then((VMService vmservice) {
                printTrace('Successfully connected to service protocol: $processObservatoryUri');
              });
            }
            gotProcessObservatoryUri.complete();
            watcher?.handleStartedProcess(
                ProcessEvent(ourTestCount, process, processObservatoryUri));
  