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 _pause = Symbol('_pause'); | 17 let _pause = Symbol('_pause'); |
18 class Isolate extends core.Object { | 18 class Isolate extends core.Object { |
19 Isolate(controlPort, opt$) { | 19 Isolate(controlPort, opts) { |
20 let pauseCapability = opt$ && 'pauseCapability' in opt$ ? opt$.pauseCapabi
lity : null; | 20 let pauseCapability = opts && 'pauseCapability' in opts ? opts.pauseCapabi
lity : null; |
21 let terminateCapability = opt$ && 'terminateCapability' in opt$ ? opt$.ter
minateCapability : null; | 21 let terminateCapability = opts && 'terminateCapability' in opts ? opts.ter
minateCapability : null; |
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 _currentIsolateCache; | 27 return _currentIsolateCache; |
28 } | 28 } |
29 static spawn(entryPoint, message, opt$) { | 29 static spawn(entryPoint, message, opts) { |
30 let paused = opt$ && 'paused' in opt$ ? opt$.paused : false; | 30 let paused = opts && 'paused' in opts ? opts.paused : false; |
31 try { | 31 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)); | 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, opts) { |
40 let paused = opt$ && 'paused' in opt$ ? opt$.paused : false; | 40 let paused = opts && 'paused' in opts ? opts.paused : false; |
41 let packageRoot = opt$ && 'packageRoot' in opt$ ? opt$.packageRoot : null; | 41 let packageRoot = opts && 'packageRoot' in opts ? opts.packageRoot : null; |
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) { |
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
186 RemoteError(description, stackDescription) { | 186 RemoteError(description, stackDescription) { |
187 this[_description] = description; | 187 this[_description] = description; |
188 this.stackTrace = new _RemoteStackTrace(stackDescription); | 188 this.stackTrace = new _RemoteStackTrace(stackDescription); |
189 } | 189 } |
190 toString() { | 190 toString() { |
191 return this[_description]; | 191 return this[_description]; |
192 } | 192 } |
193 } | 193 } |
194 let _trace = Symbol('_trace'); | 194 let _trace = Symbol('_trace'); |
195 class _RemoteStackTrace extends core.Object { | 195 class _RemoteStackTrace extends core.Object { |
196 _RemoteStackTrace($_trace) { | 196 _RemoteStackTrace(trace) { |
197 this[_trace] = $_trace; | 197 this[_trace] = trace; |
198 } | 198 } |
199 toString() { | 199 toString() { |
200 return this[_trace]; | 200 return this[_trace]; |
201 } | 201 } |
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 |