| 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) { |
| 11 this.message = message; | 11 this.message = message; |
| 12 } | 12 } |
| 13 toString() { | 13 toString() { |
| 14 return `IsolateSpawnException: ${this.message}`; | 14 return `IsolateSpawnException: ${this.message}`; |
| 15 } | 15 } |
| 16 } | 16 } |
| 17 let _currentIsolateCache = Symbol('_currentIsolateCache'); |
| 17 let _pause = Symbol('_pause'); | 18 let _pause = Symbol('_pause'); |
| 18 class Isolate extends core.Object { | 19 class Isolate extends core.Object { |
| 19 Isolate(controlPort, opts) { | 20 Isolate(controlPort, opts) { |
| 20 let pauseCapability = opts && 'pauseCapability' in opts ? opts.pauseCapabi
lity : null; | 21 let pauseCapability = opts && 'pauseCapability' in opts ? opts.pauseCapabi
lity : null; |
| 21 let terminateCapability = opts && 'terminateCapability' in opts ? opts.ter
minateCapability : null; | 22 let terminateCapability = opts && 'terminateCapability' in opts ? opts.ter
minateCapability : null; |
| 22 this.controlPort = controlPort; | 23 this.controlPort = controlPort; |
| 23 this.pauseCapability = pauseCapability; | 24 this.pauseCapability = pauseCapability; |
| 24 this.terminateCapability = terminateCapability; | 25 this.terminateCapability = terminateCapability; |
| 25 } | 26 } |
| 26 static get current() { | 27 static get current() { |
| 27 return _currentIsolateCache; | 28 return Isolate[_currentIsolateCache]; |
| 28 } | 29 } |
| 29 static spawn(entryPoint, message, opts) { | 30 static spawn(entryPoint, message, opts) { |
| 30 let paused = opts && 'paused' in opts ? opts.paused : false; | 31 let paused = opts && 'paused' in opts ? opts.paused : false; |
| 31 try { | 32 try { |
| 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 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) { | 34 } catch (e) { |
| 34 let st = dart.stackTrace(e); | 35 let st = dart.stackTrace(e); |
| 35 return new async.Future.error(e, st); | 36 return new async.Future.error(e, st); |
| 36 } | 37 } |
| 37 | 38 |
| (...skipping 164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 202 } | 203 } |
| 203 // Exports: | 204 // Exports: |
| 204 exports.Capability = Capability; | 205 exports.Capability = Capability; |
| 205 exports.IsolateSpawnException = IsolateSpawnException; | 206 exports.IsolateSpawnException = IsolateSpawnException; |
| 206 exports.Isolate = Isolate; | 207 exports.Isolate = Isolate; |
| 207 exports.SendPort = SendPort; | 208 exports.SendPort = SendPort; |
| 208 exports.ReceivePort = ReceivePort; | 209 exports.ReceivePort = ReceivePort; |
| 209 exports.RawReceivePort = RawReceivePort; | 210 exports.RawReceivePort = RawReceivePort; |
| 210 exports.RemoteError = RemoteError; | 211 exports.RemoteError = RemoteError; |
| 211 })(isolate || (isolate = {})); | 212 })(isolate || (isolate = {})); |
| OLD | NEW |