| Index: sdk/lib/isolate/isolate.dart
|
| diff --git a/sdk/lib/isolate/isolate.dart b/sdk/lib/isolate/isolate.dart
|
| index 8627be5b9a18c8bfc933a58e607ac8a86f6967b2..cf459f5eb517fcfd8f94a7d38899b82ace03df95 100644
|
| --- a/sdk/lib/isolate/isolate.dart
|
| +++ b/sdk/lib/isolate/isolate.dart
|
| @@ -133,8 +133,7 @@ class Isolate {
|
| * pause or terminate the isolate. All the untrusted code can do is to
|
| * inspect the isolate and see uncaught errors or when it terminates.
|
| */
|
| - Isolate(this.controlPort, {this.pauseCapability,
|
| - this.terminateCapability});
|
| + Isolate(this.controlPort, {this.pauseCapability, this.terminateCapability});
|
|
|
| /**
|
| * Return an [Isolate] object representing the current isolate.
|
| @@ -226,10 +225,10 @@ class Isolate {
|
| * spawning succeeded. It will complete with an error otherwise.
|
| */
|
| external static Future<Isolate> spawn(void entryPoint(message), var message,
|
| - {bool paused: false,
|
| - bool errorsAreFatal,
|
| - SendPort onExit,
|
| - SendPort onError});
|
| + {bool paused: false,
|
| + bool errorsAreFatal,
|
| + SendPort onExit,
|
| + SendPort onError});
|
|
|
| /**
|
| * Creates and spawns an isolate that runs the code from the library with
|
| @@ -308,18 +307,16 @@ class Isolate {
|
| * spawning succeeded. It will complete with an error otherwise.
|
| */
|
| external static Future<Isolate> spawnUri(
|
| - Uri uri,
|
| - List<String> args,
|
| - var message,
|
| + Uri uri, List<String> args, var message,
|
| {bool paused: false,
|
| - SendPort onExit,
|
| - SendPort onError,
|
| - bool errorsAreFatal,
|
| - bool checked,
|
| - Map<String, String> environment,
|
| - Uri packageRoot,
|
| - Uri packageConfig,
|
| - bool automaticPackageResolution: false});
|
| + SendPort onExit,
|
| + SendPort onError,
|
| + bool errorsAreFatal,
|
| + bool checked,
|
| + Map<String, String> environment,
|
| + Uri packageRoot,
|
| + Uri packageConfig,
|
| + bool automaticPackageResolution: false});
|
|
|
| /**
|
| * Requests the isolate to pause.
|
| @@ -497,8 +494,8 @@ class Isolate {
|
| * after the current event, and any already scheduled control events,
|
| * are completed.
|
| */
|
| - external void ping(SendPort responsePort, {Object response,
|
| - int priority: IMMEDIATE});
|
| + external void ping(SendPort responsePort,
|
| + {Object response, int priority: IMMEDIATE});
|
|
|
| /**
|
| * Requests that uncaught errors of the isolate are sent back to [port].
|
| @@ -560,6 +557,7 @@ class Isolate {
|
| var error = new RemoteError(errorDescription, stackDescription);
|
| controller.addError(error, error.stackTrace);
|
| }
|
| +
|
| controller = new StreamController.broadcast(
|
| sync: true,
|
| onListen: () {
|
| @@ -586,7 +584,6 @@ class Isolate {
|
| * when sent.
|
| */
|
| abstract class SendPort implements Capability {
|
| -
|
| /**
|
| * Sends an asynchronous [message] through this send port, to its
|
| * corresponding `ReceivePort`.
|
| @@ -611,7 +608,7 @@ abstract class SendPort implements Capability {
|
| * Tests whether [other] is a [SendPort] pointing to the same
|
| * [ReceivePort] as this one.
|
| */
|
| - bool operator==(var other);
|
| + bool operator ==(var other);
|
|
|
| /**
|
| * Returns an immutable hash code for this send port that is
|
| @@ -636,7 +633,6 @@ abstract class SendPort implements Capability {
|
| * A [ReceivePort] may have many [SendPort]s.
|
| */
|
| abstract class ReceivePort implements Stream {
|
| -
|
| /**
|
| * Opens a long-lived port for receiving messages.
|
| *
|
| @@ -667,9 +663,7 @@ abstract class ReceivePort implements Stream {
|
| * The stream closes when [close] is called.
|
| */
|
| StreamSubscription listen(void onData(var message),
|
| - { Function onError,
|
| - void onDone(),
|
| - bool cancelOnError });
|
| + {Function onError, void onDone(), bool cancelOnError});
|
|
|
| /**
|
| * Closes `this`.
|
|
|