spawnHybridUri function

StreamChannel spawnHybridUri (dynamic uri, { Object message, bool stayAlive: false })

Spawns a VM isolate for the given uri, which may be a Uri or a String.

This allows browser tests to spawn servers with which they can communicate to test client/server interactions. It can also be used by VM tests to easily spawn an isolate.

The Dart file at uri must define a top-level hybridMain() function that takes a StreamChannel argument and, optionally, an Object argument to which message will be passed. Note that message must be JSON-encodable. For example:

import "package:stream_channel/stream_channel.dart";

hybridMain(StreamChannel channel, Object message) {
  // ...
}

If uri is relative, it will be interpreted relative to the file: URL for the test suite being executed. If it's root-relative (that is, if it begins with /) it will be interpreted relative to the root of the package (the directory that contains pubspec.yaml, not the test/ directory). If it's a package: URL, it will be resolved using the current package's dependency constellation.

Returns a StreamChannel that's connected to the channel passed to hybridMain(). Only JSON-encodable objects may be sent through this channel. If the channel is closed, the hybrid isolate is killed. If the isolate is killed, the channel's stream will emit a "done" event.

Any unhandled errors loading or running the hybrid isolate will be emitted as errors over the channel's stream. Any calls to print() in the hybrid isolate will be printed as though they came from the test that created the isolate.

Code in the hybrid isolate is not considered to be running in a test context, so it can't access test functions like expect() and expectAsync().

By default, the hybrid isolate is automatically killed when the test finishes running. If stayAlive is true, it won't be killed until the entire test suite finishes running.

Note: If you use this API, be sure to add a dependency on the **stream_channel package, since you're using its API as well!

Implementation 

StreamChannel spawnHybridUri(uri, {Object message, bool stayAlive = false}) {
  Uri parsedUrl;
  if (uri is Uri) {
    parsedUrl = uri;
  } else if (uri is String) {
    parsedUrl = Uri.parse(uri);
  } else {
    throw ArgumentError.value(uri, "uri", "must be a Uri or a String.");
  }

  String absoluteUri;
  if (parsedUrl.scheme.isEmpty) {
    var isRootRelative = parsedUrl.path.startsWith("/");

    // If we're running in a browser context, the working directory is already
    // relative to the test file, whereas on the VM the working directory is the
    // root of the package.
    if (p.style == p.Style.url) {
      if (isRootRelative) {
        // A root-relative URL is interpreted as relative to the package root,
        // which means placing it beneath the URL secret.
        var secret = Uri.encodeComponent(Uri.base.pathSegments[0]);
        absoluteUri = p.absolute("/$secret$parsedUrl");
        print("Uri.base: ${Uri.base}");
        print("absoluteUri: ${absoluteUri}");
      } else {
        absoluteUri = p.absolute(parsedUrl.toString());
      }
    } else {
      if (isRootRelative) {
        // We assume that the current path is the package root. `pub run`
        // enforces this currently, but at some point it would probably be good
        // to pass in an explicit root.
        absoluteUri = p.url
            .join(p.toUri(p.current).toString(), parsedUrl.path.substring(1));
      } else {
        var suitePath = Invoker.current.liveTest.suite.path;
        absoluteUri = p.url.join(
            p.url.dirname(p.toUri(p.absolute(suitePath)).toString()),
            parsedUrl.toString());
      }
    }
  } else {
    absoluteUri = uri.toString();
  }

  return _spawn(absoluteUri, message, stayAlive: stayAlive);
}