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 26 matching lines...) Expand all Loading... |
37 | 37 |
38 } | 38 } |
39 static spawnUri(uri, args, message, opts) { | 39 static spawnUri(uri, args, message, opts) { |
40 let paused = opts && 'paused' in opts ? opts.paused : false; | 40 let paused = opts && 'paused' in opts ? opts.paused : false; |
41 let packageRoot = opts && 'packageRoot' in opts ? opts.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) { |
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(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)); | 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); |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
94 setErrorsFatal(errorsAreFatal) { | 94 setErrorsFatal(errorsAreFatal) { |
95 let message = new core.List(3); | 95 let message = new core.List(3); |
96 dart.dsetindex(message, 0, "set-errors-fatal"); | 96 dart.dsetindex(message, 0, "set-errors-fatal"); |
97 dart.dsetindex(message, 1, this.terminateCapability); | 97 dart.dsetindex(message, 1, this.terminateCapability); |
98 dart.dsetindex(message, 2, errorsAreFatal); | 98 dart.dsetindex(message, 2, errorsAreFatal); |
99 this.controlPort.send(message); | 99 this.controlPort.send(message); |
100 } | 100 } |
101 kill(priority) { | 101 kill(priority) { |
102 if (priority === void 0) | 102 if (priority === void 0) |
103 priority = Isolate.BEFORE_NEXT_EVENT; | 103 priority = Isolate.BEFORE_NEXT_EVENT; |
104 this.controlPort.send(new List.from(["kill", this.terminateCapability, pri
ority])); | 104 this.controlPort.send(new core.List.from(["kill", this.terminateCapability
, priority])); |
105 } | 105 } |
106 ping(responsePort, pingType) { | 106 ping(responsePort, pingType) { |
107 if (pingType === void 0) | 107 if (pingType === void 0) |
108 pingType = Isolate.IMMEDIATE; | 108 pingType = Isolate.IMMEDIATE; |
109 let message = new core.List(3); | 109 let message = new core.List(3); |
110 dart.dsetindex(message, 0, "ping"); | 110 dart.dsetindex(message, 0, "ping"); |
111 dart.dsetindex(message, 1, responsePort); | 111 dart.dsetindex(message, 1, responsePort); |
112 dart.dsetindex(message, 2, pingType); | 112 dart.dsetindex(message, 2, pingType); |
113 this.controlPort.send(message); | 113 this.controlPort.send(message); |
114 } | 114 } |
(...skipping 87 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 |