| OLD | NEW |
| 1 var isolate; | 1 var isolate; |
| 2 (function(exports) { | 2 (function(exports) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 class Capability extends core.Object { | 4 class Capability extends core.Object { |
| 5 Capability() { | 5 Capability() { |
| 6 return new _isolate_helper.CapabilityImpl(); | 6 return new _isolate_helper.CapabilityImpl(); |
| 7 } | 7 } |
| 8 } | 8 } |
| 9 class IsolateSpawnException extends core.Object { | 9 class IsolateSpawnException extends core.Object { |
| 10 IsolateSpawnException(message) { | 10 IsolateSpawnException(message) { |
| (...skipping 11 matching lines...) Expand all Loading... |
| 22 this.controlPort = controlPort; | 22 this.controlPort = controlPort; |
| 23 this.pauseCapability = pauseCapability; | 23 this.pauseCapability = pauseCapability; |
| 24 this.terminateCapability = terminateCapability; | 24 this.terminateCapability = terminateCapability; |
| 25 } | 25 } |
| 26 static get current() { | 26 static get current() { |
| 27 return dart.as(_currentIsolateCache, Isolate); | 27 return dart.as(_currentIsolateCache, Isolate); |
| 28 } | 28 } |
| 29 static spawn(entryPoint, message, opt$) { | 29 static spawn(entryPoint, message, opt$) { |
| 30 let paused = opt$.paused === void 0 ? false : opt$.paused; | 30 let paused = opt$.paused === void 0 ? false : opt$.paused; |
| 31 try { | 31 try { |
| 32 return dart.as(_isolate_helper.IsolateNatives.spawnFunction(entryPoint,
message, paused).then((msg) => new Isolate(dart.as(dart.dindex(msg, 1), SendPort
), {pauseCapability: dart.as(dart.dindex(msg, 2), Capability), terminateCapabili
ty: dart.as(dart.dindex(msg, 3), Capability)})), async.Future$(Isolate)); | 32 return dart.as(_isolate_helper.IsolateNatives.spawnFunction(entryPoint,
message, paused).then(dart.closureWrap((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)}), "(List<dynamic>
) → dynamic")), async.Future$(Isolate)); |
| 33 } catch (e) { | 33 } catch (e) { |
| 34 let st = dart.stackTrace(e); | 34 let st = dart.stackTrace(e); |
| 35 return new async.Future.error(e, st); | 35 return new async.Future.error(e, st); |
| 36 } | 36 } |
| 37 | 37 |
| 38 } | 38 } |
| 39 static spawnUri(uri, args, message, opt$) { | 39 static spawnUri(uri, args, message, opt$) { |
| 40 let paused = opt$.paused === void 0 ? false : opt$.paused; | 40 let paused = opt$.paused === void 0 ? false : opt$.paused; |
| 41 let packageRoot = opt$.packageRoot === void 0 ? null : opt$.packageRoot; | 41 let packageRoot = opt$.packageRoot === void 0 ? null : opt$.packageRoot; |
| 42 if (packageRoot !== null) | 42 if (packageRoot !== null) |
| 43 throw new core.UnimplementedError("packageRoot"); | 43 throw new core.UnimplementedError("packageRoot"); |
| 44 try { | 44 try { |
| 45 if (dart.is(args, core.List$(core.String))) { | 45 if (dart.is(args, core.List$(core.String))) { |
| 46 for (let i = 0; dart.notNull(i) < dart.notNull(args.length); i = dart.
notNull(i) + 1) { | 46 for (let i = 0; dart.notNull(i) < dart.notNull(args.length); i = dart.
notNull(i) + 1) { |
| 47 if (!(typeof args.get(i) == string)) { | 47 if (!(typeof args.get(i) == string)) { |
| 48 throw new core.ArgumentError(`Args must be a list of Strings ${arg
s}`); | 48 throw new core.ArgumentError(`Args must be a list of Strings ${arg
s}`); |
| 49 } | 49 } |
| 50 } | 50 } |
| 51 } else if (args !== null) { | 51 } else if (args !== null) { |
| 52 throw new core.ArgumentError(`Args must be a list of Strings ${args}`)
; | 52 throw new core.ArgumentError(`Args must be a list of Strings ${args}`)
; |
| 53 } | 53 } |
| 54 return dart.as(_isolate_helper.IsolateNatives.spawnUri(uri, args, messag
e, paused).then((msg) => new Isolate(dart.as(dart.dindex(msg, 1), SendPort), {pa
useCapability: dart.as(dart.dindex(msg, 2), Capability), terminateCapability: da
rt.as(dart.dindex(msg, 3), Capability)})), async.Future$(Isolate)); | 54 return dart.as(_isolate_helper.IsolateNatives.spawnUri(uri, args, messag
e, paused).then(dart.closureWrap((msg) => new Isolate(dart.as(dart.dindex(msg, 1
), SendPort), {pauseCapability: dart.as(dart.dindex(msg, 2), Capability), termin
ateCapability: dart.as(dart.dindex(msg, 3), Capability)}), "(List<dynamic>) → dy
namic")), async.Future$(Isolate)); |
| 55 } catch (e) { | 55 } catch (e) { |
| 56 let st = dart.stackTrace(e); | 56 let st = dart.stackTrace(e); |
| 57 return new async.Future.error(e, st); | 57 return new async.Future.error(e, st); |
| 58 } | 58 } |
| 59 | 59 |
| 60 } | 60 } |
| 61 pause(resumeCapability) { | 61 pause(resumeCapability) { |
| 62 if (resumeCapability === void 0) | 62 if (resumeCapability === void 0) |
| 63 resumeCapability = null; | 63 resumeCapability = null; |
| 64 if (resumeCapability === null) | 64 if (resumeCapability === null) |
| (...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 202 } | 202 } |
| 203 // Exports: | 203 // Exports: |
| 204 exports.Capability = Capability; | 204 exports.Capability = Capability; |
| 205 exports.IsolateSpawnException = IsolateSpawnException; | 205 exports.IsolateSpawnException = IsolateSpawnException; |
| 206 exports.Isolate = Isolate; | 206 exports.Isolate = Isolate; |
| 207 exports.SendPort = SendPort; | 207 exports.SendPort = SendPort; |
| 208 exports.ReceivePort = ReceivePort; | 208 exports.ReceivePort = ReceivePort; |
| 209 exports.RawReceivePort = RawReceivePort; | 209 exports.RawReceivePort = RawReceivePort; |
| 210 exports.RemoteError = RemoteError; | 210 exports.RemoteError = RemoteError; |
| 211 })(isolate || (isolate = {})); | 211 })(isolate || (isolate = {})); |
| OLD | NEW |