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 dart.initField(IsolateSpawnException, this, 'message', message); |
12 } | 12 } |
13 toString() { | 13 toString() { |
14 return `IsolateSpawnException: ${this.message}`; | 14 return `IsolateSpawnException: ${this.message}`; |
15 } | 15 } |
16 } | 16 } |
17 IsolateSpawnException[dart.implements] = () => [core.Exception]; | 17 IsolateSpawnException[dart.implements] = () => [core.Exception]; |
18 let _currentIsolateCache = Symbol('_currentIsolateCache'); | 18 let _currentIsolateCache = Symbol('_currentIsolateCache'); |
19 let _pause = Symbol('_pause'); | 19 let _pause = Symbol('_pause'); |
20 class Isolate extends core.Object { | 20 class Isolate extends core.Object { |
21 Isolate(controlPort, opts) { | 21 Isolate(controlPort, opts) { |
22 let pauseCapability = opts && 'pauseCapability' in opts ? opts.pauseCapabi
lity : null; | 22 let pauseCapability = opts && 'pauseCapability' in opts ? opts.pauseCapabi
lity : null; |
23 let terminateCapability = opts && 'terminateCapability' in opts ? opts.ter
minateCapability : null; | 23 let terminateCapability = opts && 'terminateCapability' in opts ? opts.ter
minateCapability : null; |
24 this.controlPort = controlPort; | 24 dart.initField(Isolate, this, 'controlPort', controlPort); |
25 this.pauseCapability = pauseCapability; | 25 dart.initField(Isolate, this, 'pauseCapability', pauseCapability); |
26 this.terminateCapability = terminateCapability; | 26 dart.initField(Isolate, this, 'terminateCapability', terminateCapability); |
27 } | 27 } |
28 static get current() { | 28 static get current() { |
29 return Isolate[_currentIsolateCache]; | 29 return Isolate[_currentIsolateCache]; |
30 } | 30 } |
31 static spawn(entryPoint, message, opts) { | 31 static spawn(entryPoint, message, opts) { |
32 let paused = opts && 'paused' in opts ? opts.paused : false; | 32 let paused = opts && 'paused' in opts ? opts.paused : false; |
33 try { | 33 try { |
34 return dart.as(_isolate_helper.IsolateNatives.spawnFunction(entryPoint,
message, paused).then(dart.as(msg => new Isolate(dart.as(dart.dindex(msg, 1), Se
ndPort), {pauseCapability: dart.as(dart.dindex(msg, 2), Capability), terminateCa
pability: dart.as(dart.dindex(msg, 3), Capability)}), dart.functionType(dart.dyn
amic, [core.List]))), async.Future$(Isolate)); | 34 return dart.as(_isolate_helper.IsolateNatives.spawnFunction(entryPoint,
message, paused).then(dart.as(msg => new Isolate(dart.as(dart.dindex(msg, 1), Se
ndPort), {pauseCapability: dart.as(dart.dindex(msg, 2), Capability), terminateCa
pability: dart.as(dart.dindex(msg, 3), Capability)}), dart.functionType(dart.dyn
amic, [core.List]))), async.Future$(Isolate)); |
35 } catch (e) { | 35 } catch (e) { |
36 let st = dart.stackTrace(e); | 36 let st = dart.stackTrace(e); |
(...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
185 this.stackTrace = stackTrace; | 185 this.stackTrace = stackTrace; |
186 } | 186 } |
187 toString() { | 187 toString() { |
188 return 'IsolateUnhandledException: exception while handling message: ' + `
${this.message} \n ` + `${this.source.toString().replaceAll("\n", "\n ")}\n` +
'original stack trace:\n ' + `${this.stackTrace.toString().replaceAll("\n", "\
n ")}`; | 188 return 'IsolateUnhandledException: exception while handling message: ' + `
${this.message} \n ` + `${this.source.toString().replaceAll("\n", "\n ")}\n` +
'original stack trace:\n ' + `${this.stackTrace.toString().replaceAll("\n", "\
n ")}`; |
189 } | 189 } |
190 } | 190 } |
191 _IsolateUnhandledException[dart.implements] = () => [core.Exception]; | 191 _IsolateUnhandledException[dart.implements] = () => [core.Exception]; |
192 let _description = Symbol('_description'); | 192 let _description = Symbol('_description'); |
193 class RemoteError extends core.Object { | 193 class RemoteError extends core.Object { |
194 RemoteError(description, stackDescription) { | 194 RemoteError(description, stackDescription) { |
195 this[_description] = description; | 195 dart.initField(RemoteError, this, _description, description); |
196 this.stackTrace = new _RemoteStackTrace(stackDescription); | 196 dart.initField(RemoteError, this, 'stackTrace', new _RemoteStackTrace(stac
kDescription)); |
197 } | 197 } |
198 toString() { | 198 toString() { |
199 return this[_description]; | 199 return this[_description]; |
200 } | 200 } |
201 } | 201 } |
202 RemoteError[dart.implements] = () => [core.Error]; | 202 RemoteError[dart.implements] = () => [core.Error]; |
203 let _trace = Symbol('_trace'); | 203 let _trace = Symbol('_trace'); |
204 class _RemoteStackTrace extends core.Object { | 204 class _RemoteStackTrace extends core.Object { |
205 _RemoteStackTrace(trace) { | 205 _RemoteStackTrace(trace) { |
206 this[_trace] = trace; | 206 this[_trace] = trace; |
207 } | 207 } |
208 toString() { | 208 toString() { |
209 return this[_trace]; | 209 return this[_trace]; |
210 } | 210 } |
211 } | 211 } |
212 _RemoteStackTrace[dart.implements] = () => [core.StackTrace]; | 212 _RemoteStackTrace[dart.implements] = () => [core.StackTrace]; |
213 // Exports: | 213 // Exports: |
214 exports.Capability = Capability; | 214 exports.Capability = Capability; |
215 exports.IsolateSpawnException = IsolateSpawnException; | 215 exports.IsolateSpawnException = IsolateSpawnException; |
216 exports.Isolate = Isolate; | 216 exports.Isolate = Isolate; |
217 exports.SendPort = SendPort; | 217 exports.SendPort = SendPort; |
218 exports.ReceivePort = ReceivePort; | 218 exports.ReceivePort = ReceivePort; |
219 exports.RawReceivePort = RawReceivePort; | 219 exports.RawReceivePort = RawReceivePort; |
220 exports.RemoteError = RemoteError; | 220 exports.RemoteError = RemoteError; |
221 })(isolate || (isolate = {})); | 221 })(isolate || (isolate = {})); |
OLD | NEW |