anchor.diff:            globals.printTrace('test $ourTestCount: waiting for controller sink to close');
             await controller.sink.done;
             await watcher?.handleTestCrashed(ProcessEvent(ourTestCount, process));
  -          break;
  -        case InitialResult.timedOut:
  -          // Could happen either if the process takes a long time starting
  -          // (_kTestProcessTimeout), or if once Dart code starts running, it takes a
  -          // long time to open the WebSocket connection (_kTestStartupTimeout).
  -          globals.printTrace('test $ourTestCount: timed out waiting for process with pid ${process.pid} to connect to test harness');
  -          final String message = _getErrorMessage('Test never connected to test harness.', testPath, shellPath);
  -          controller.sink.addError(message);
  -          // Awaited for with 'sink.done' below.
  -          unawaited(controller.sink.close());
  -          globals.printTrace('test $ourTestCount: waiting for controller sink to close');
  -          await controller.sink.done;
  -          await watcher
  -              ?.handleTestTimedOut(ProcessEvent(ourTestCount, process));
             break;
           case InitialResult.connected:
             globals.printTrace('test $ourTestCount: process with pid ${process.pid} connected to test harness');
  
positive.code:           watcher?.handleStartedProcess(
                ProcessEvent(ourTestCount, process, processObservatoryUri));
          },
          startTimeoutTimer: () {
            Future<InitialResult>.delayed(_kTestStartupTimeout)
                .then<void>((_) => timeout.complete());
          },
        );
  
        // At this point, three things can happen next:
  
negative.code: 
  
  void main() {
    String serverPort = Platform.environment['SERVER_PORT'] ?? '';
    String server = Uri.decodeComponent('$encodedWebsocketUrl:\$serverPort');
    StreamChannel<dynamic> channel = serializeSuite(() {
  