Index: lib/runtime/dart/isolate.js |
diff --git a/lib/runtime/dart/isolate.js b/lib/runtime/dart/isolate.js |
index 202273713ace4034b4ab0a48a2a38dfbd2a98ea2..f5e75ec6838f6a87148a29cc7573dba794b8b476 100644 |
--- a/lib/runtime/dart/isolate.js |
+++ b/lib/runtime/dart/isolate.js |
@@ -42,7 +42,7 @@ dart_library.library('dart/isolate', null, /* Imports */[ |
static spawn(entryPoint, message, opts) { |
let paused = opts && 'paused' in opts ? opts.paused : false; |
try { |
- return _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, [dart.dynamic])); |
+ return _isolate_helper.IsolateNatives.spawnFunction(entryPoint, message, paused).then(dart.fn(msg => new Isolate(dart.as(msg[dartx.get](1), SendPort), {pauseCapability: dart.as(msg[dartx.get](2), Capability), terminateCapability: dart.as(msg[dartx.get](3), Capability)}), Isolate, [core.List])); |
} catch (e) { |
let st = dart.stackTrace(e); |
return async.Future$(Isolate).error(e, st); |
@@ -63,7 +63,7 @@ dart_library.library('dart/isolate', null, /* Imports */[ |
} else if (args != null) { |
dart.throw(new core.ArgumentError(`Args must be a list of Strings ${args}`)); |
} |
- return _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, [dart.dynamic])); |
+ return _isolate_helper.IsolateNatives.spawnUri(uri, args, message, paused).then(dart.fn(msg => new Isolate(dart.as(msg[dartx.get](1), SendPort), {pauseCapability: dart.as(msg[dartx.get](2), Capability), terminateCapability: dart.as(msg[dartx.get](3), Capability)}), Isolate, [core.List])); |
} catch (e) { |
let st = dart.stackTrace(e); |
return async.Future$(Isolate).error(e, st); |
@@ -145,11 +145,11 @@ dart_library.library('dart/isolate', null, /* Imports */[ |
controller = async.StreamController.broadcast({sync: true, onListen: dart.fn((() => { |
port = RawReceivePort.new(handleError); |
this.addErrorListener(port.sendPort); |
- }).bind(this)), onCancel: dart.fn((() => { |
+ }).bind(this), dart.void, []), onCancel: dart.fn((() => { |
this.removeErrorListener(port.sendPort); |
port.close(); |
port = null; |
- }).bind(this))}); |
+ }).bind(this), dart.void, [])}); |
return controller.stream; |
} |
} |