| Index: lib/runtime/dart/isolate.js
|
| diff --git a/lib/runtime/dart/isolate.js b/lib/runtime/dart/isolate.js
|
| index 30a7b5ee0da4cb879cd939ef75051d98b6f41726..d221567d2f5812aaa277a5c0e2859526dbfbe82f 100644
|
| --- a/lib/runtime/dart/isolate.js
|
| +++ b/lib/runtime/dart/isolate.js
|
| @@ -5,12 +5,12 @@ var async = dart.import(async);
|
| (function(exports, core, _isolate_helper, async) {
|
| 'use strict';
|
| class Capability extends core.Object {
|
| - Capability() {
|
| + static new() {
|
| return new _isolate_helper.CapabilityImpl();
|
| }
|
| }
|
| dart.setSignature(Capability, {
|
| - constructors: () => ({Capability: [Capability, []]})
|
| + constructors: () => ({new: [Capability, []]})
|
| });
|
| class IsolateSpawnException extends core.Object {
|
| IsolateSpawnException(message) {
|
| @@ -42,7 +42,7 @@ var async = dart.import(async);
|
| return dart.as(_isolate_helper.IsolateNatives.spawnFunction(entryPoint, message, paused).then(dart.fn(msg => new Isolate(dart.as(dart.dindex(msg, 1), SendPort), {pauseCapability: dart.as(dart.dindex(msg, 2), Capability), terminateCapability: dart.as(dart.dindex(msg, 3), Capability)}), Isolate, [core.Object])), async.Future$(Isolate));
|
| } catch (e) {
|
| let st = dart.stackTrace(e);
|
| - return new (async.Future$(Isolate)).error(e, st);
|
| + return async.Future$(Isolate).error(e, st);
|
| }
|
|
|
| }
|
| @@ -64,7 +64,7 @@ var async = dart.import(async);
|
| return dart.as(_isolate_helper.IsolateNatives.spawnUri(uri, args, message, paused).then(dart.fn(msg => new Isolate(dart.as(dart.dindex(msg, 1), SendPort), {pauseCapability: dart.as(dart.dindex(msg, 2), Capability), terminateCapability: dart.as(dart.dindex(msg, 3), Capability)}), Isolate, [core.Object])), async.Future$(Isolate));
|
| } catch (e) {
|
| let st = dart.stackTrace(e);
|
| - return new (async.Future$(Isolate)).error(e, st);
|
| + return async.Future$(Isolate).error(e, st);
|
| }
|
|
|
| }
|
| @@ -72,37 +72,37 @@ var async = dart.import(async);
|
| if (resumeCapability === void 0)
|
| resumeCapability = null;
|
| if (resumeCapability == null)
|
| - resumeCapability = new Capability();
|
| + resumeCapability = Capability.new();
|
| this[_pause](resumeCapability);
|
| return resumeCapability;
|
| }
|
| [_pause](resumeCapability) {
|
| - let message = new core.List(3);
|
| + let message = core.List.new(3);
|
| message[core.$set](0, "pause");
|
| message[core.$set](1, this.pauseCapability);
|
| message[core.$set](2, resumeCapability);
|
| this.controlPort.send(message);
|
| }
|
| resume(resumeCapability) {
|
| - let message = new core.List(2);
|
| + let message = core.List.new(2);
|
| message[core.$set](0, "resume");
|
| message[core.$set](1, resumeCapability);
|
| this.controlPort.send(message);
|
| }
|
| addOnExitListener(responsePort) {
|
| - let message = new core.List(2);
|
| + let message = core.List.new(2);
|
| message[core.$set](0, "add-ondone");
|
| message[core.$set](1, responsePort);
|
| this.controlPort.send(message);
|
| }
|
| removeOnExitListener(responsePort) {
|
| - let message = new core.List(2);
|
| + let message = core.List.new(2);
|
| message[core.$set](0, "remove-ondone");
|
| message[core.$set](1, responsePort);
|
| this.controlPort.send(message);
|
| }
|
| setErrorsFatal(errorsAreFatal) {
|
| - let message = new core.List(3);
|
| + let message = core.List.new(3);
|
| message[core.$set](0, "set-errors-fatal");
|
| message[core.$set](1, this.terminateCapability);
|
| message[core.$set](2, errorsAreFatal);
|
| @@ -116,20 +116,20 @@ var async = dart.import(async);
|
| ping(responsePort, pingType) {
|
| if (pingType === void 0)
|
| pingType = Isolate.IMMEDIATE;
|
| - let message = new core.List(3);
|
| + let message = core.List.new(3);
|
| message[core.$set](0, "ping");
|
| message[core.$set](1, responsePort);
|
| message[core.$set](2, pingType);
|
| this.controlPort.send(message);
|
| }
|
| addErrorListener(port) {
|
| - let message = new core.List(2);
|
| + let message = core.List.new(2);
|
| message[core.$set](0, "getErrors");
|
| message[core.$set](1, port);
|
| this.controlPort.send(message);
|
| }
|
| removeErrorListener(port) {
|
| - let message = new core.List(2);
|
| + let message = core.List.new(2);
|
| message[core.$set](0, "stopErrors");
|
| message[core.$set](1, port);
|
| this.controlPort.send(message);
|
| @@ -144,8 +144,8 @@ var async = dart.import(async);
|
| controller.addError(error, error.stackTrace);
|
| };
|
| dart.fn(handleError, dart.void, [core.Object]);
|
| - controller = new async.StreamController.broadcast({sync: true, onListen: dart.fn((() => {
|
| - port = new RawReceivePort(handleError);
|
| + controller = async.StreamController.broadcast({sync: true, onListen: dart.fn((() => {
|
| + port = RawReceivePort.new(handleError);
|
| this.addErrorListener(port.sendPort);
|
| }).bind(this)), onCancel: dart.fn((() => {
|
| this.removeErrorListener(port.sendPort);
|
| @@ -186,30 +186,29 @@ var async = dart.import(async);
|
| class SendPort extends core.Object {}
|
| SendPort[dart.implements] = () => [Capability];
|
| class ReceivePort extends core.Object {
|
| - ReceivePort() {
|
| + static new() {
|
| return new _isolate_helper.ReceivePortImpl();
|
| }
|
| - fromRawReceivePort(rawPort) {
|
| + static fromRawReceivePort(rawPort) {
|
| return new _isolate_helper.ReceivePortImpl.fromRawReceivePort(rawPort);
|
| }
|
| }
|
| ReceivePort[dart.implements] = () => [async.Stream];
|
| - dart.defineNamedConstructor(ReceivePort, 'fromRawReceivePort');
|
| dart.setSignature(ReceivePort, {
|
| constructors: () => ({
|
| - ReceivePort: [ReceivePort, []],
|
| + new: [ReceivePort, []],
|
| fromRawReceivePort: [ReceivePort, [RawReceivePort]]
|
| })
|
| });
|
| class RawReceivePort extends core.Object {
|
| - RawReceivePort(handler) {
|
| + static new(handler) {
|
| if (handler === void 0)
|
| handler = null;
|
| return new _isolate_helper.RawReceivePortImpl(handler);
|
| }
|
| }
|
| dart.setSignature(RawReceivePort, {
|
| - constructors: () => ({RawReceivePort: [RawReceivePort, [], [dart.functionType(dart.void, [dart.bottom])]]})
|
| + constructors: () => ({new: [RawReceivePort, [], [dart.functionType(dart.void, [dart.bottom])]]})
|
| });
|
| class _IsolateUnhandledException extends core.Object {
|
| _IsolateUnhandledException(message, source, stackTrace) {
|
|
|