OLD | NEW |
1 var isolate = dart.defineLibrary(isolate, {}); | 1 var isolate = dart.defineLibrary(isolate, {}); |
2 var core = dart.import(core); | 2 var core = dart.import(core); |
3 var _isolate_helper = dart.lazyImport(_isolate_helper); | 3 var _isolate_helper = dart.lazyImport(_isolate_helper); |
4 var async = dart.import(async); | 4 var async = dart.import(async); |
5 (function(exports, core, _isolate_helper, async) { | 5 (function(exports, core, _isolate_helper, async) { |
6 'use strict'; | 6 'use strict'; |
7 class Capability extends core.Object { | 7 class Capability extends core.Object { |
8 Capability() { | 8 Capability() { |
9 return new _isolate_helper.CapabilityImpl(); | 9 return new _isolate_helper.CapabilityImpl(); |
10 } | 10 } |
(...skipping 114 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
125 removeErrorListener(port) { | 125 removeErrorListener(port) { |
126 let message = new core.List(2); | 126 let message = new core.List(2); |
127 message[core.$set](0, "stopErrors"); | 127 message[core.$set](0, "stopErrors"); |
128 message[core.$set](1, port); | 128 message[core.$set](1, port); |
129 this.controlPort.send(message); | 129 this.controlPort.send(message); |
130 } | 130 } |
131 get errors() { | 131 get errors() { |
132 let controller = null; | 132 let controller = null; |
133 let port = null; | 133 let port = null; |
134 // Function handleError: (dynamic) → void | 134 // Function handleError: (dynamic) → void |
135 function handleError(message) { | 135 let handleError = message => { |
136 let errorDescription = dart.as(dart.dindex(message, 0), core.String); | 136 let errorDescription = dart.as(dart.dindex(message, 0), core.String); |
137 let stackDescription = dart.as(dart.dindex(message, 1), core.String); | 137 let stackDescription = dart.as(dart.dindex(message, 1), core.String); |
138 let error = new RemoteError(errorDescription, stackDescription); | 138 let error = new RemoteError(errorDescription, stackDescription); |
139 controller.addError(error, error.stackTrace); | 139 controller.addError(error, error.stackTrace); |
140 } | 140 }; |
141 controller = new async.StreamController.broadcast({ | 141 controller = new async.StreamController.broadcast({ |
142 sync: true, | 142 sync: true, |
143 onListen: (() => { | 143 onListen: (() => { |
144 port = new RawReceivePort(handleError); | 144 port = new RawReceivePort(handleError); |
145 this.addErrorListener(port.sendPort); | 145 this.addErrorListener(port.sendPort); |
146 }).bind(this), | 146 }).bind(this), |
147 onCancel: (() => { | 147 onCancel: (() => { |
148 this.removeErrorListener(port.sendPort); | 148 this.removeErrorListener(port.sendPort); |
149 port.close(); | 149 port.close(); |
150 port = null; | 150 port = null; |
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
214 _RemoteStackTrace[dart.implements] = () => [core.StackTrace]; | 214 _RemoteStackTrace[dart.implements] = () => [core.StackTrace]; |
215 // Exports: | 215 // Exports: |
216 exports.Capability = Capability; | 216 exports.Capability = Capability; |
217 exports.IsolateSpawnException = IsolateSpawnException; | 217 exports.IsolateSpawnException = IsolateSpawnException; |
218 exports.Isolate = Isolate; | 218 exports.Isolate = Isolate; |
219 exports.SendPort = SendPort; | 219 exports.SendPort = SendPort; |
220 exports.ReceivePort = ReceivePort; | 220 exports.ReceivePort = ReceivePort; |
221 exports.RawReceivePort = RawReceivePort; | 221 exports.RawReceivePort = RawReceivePort; |
222 exports.RemoteError = RemoteError; | 222 exports.RemoteError = RemoteError; |
223 })(isolate, core, _isolate_helper, async); | 223 })(isolate, core, _isolate_helper, async); |
OLD | NEW |