| 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 22 matching lines...) Expand all Loading... |
| 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 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)); |
| 34 } catch (e) { | 34 } catch (e) { |
| 35 let st = dart.stackTrace(e); | 35 let st = dart.stackTrace(e); |
| 36 return new async.Future.error(e, st); | 36 return new async.Future.error(e, st); |
| 37 } | 37 } |
| 38 | 38 |
| 39 } | 39 } |
| 40 static spawnUri(uri, args, message, opts) { | 40 static spawnUri(uri, args, message, opts) { |
| 41 let paused = opts && 'paused' in opts ? opts.paused : false; | 41 let paused = opts && 'paused' in opts ? opts.paused : false; |
| 42 let packageRoot = opts && 'packageRoot' in opts ? opts.packageRoot : null; | 42 let packageRoot = opts && 'packageRoot' in opts ? opts.packageRoot : null; |
| 43 if (packageRoot !== null) | 43 if (packageRoot != null) |
| 44 throw new core.UnimplementedError("packageRoot"); | 44 throw new core.UnimplementedError("packageRoot"); |
| 45 try { | 45 try { |
| 46 if (dart.is(args, core.List$(core.String))) { | 46 if (dart.is(args, core.List$(core.String))) { |
| 47 for (let i = 0; dart.notNull(i) < dart.notNull(args.length); i = dart.
notNull(i) + 1) { | 47 for (let i = 0; dart.notNull(i) < dart.notNull(args.length); i = dart.
notNull(i) + 1) { |
| 48 if (!(typeof args.get(i) == 'string')) { | 48 if (!(typeof args.get(i) == 'string')) { |
| 49 throw new core.ArgumentError(`Args must be a list of Strings ${arg
s}`); | 49 throw new core.ArgumentError(`Args must be a list of Strings ${arg
s}`); |
| 50 } | 50 } |
| 51 } | 51 } |
| 52 } else if (args !== null) { | 52 } else if (args != null) { |
| 53 throw new core.ArgumentError(`Args must be a list of Strings ${args}`)
; | 53 throw new core.ArgumentError(`Args must be a list of Strings ${args}`)
; |
| 54 } | 54 } |
| 55 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 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)); |
| 56 } catch (e) { | 56 } catch (e) { |
| 57 let st = dart.stackTrace(e); | 57 let st = dart.stackTrace(e); |
| 58 return new async.Future.error(e, st); | 58 return new async.Future.error(e, st); |
| 59 } | 59 } |
| 60 | 60 |
| 61 } | 61 } |
| 62 pause(resumeCapability) { | 62 pause(resumeCapability) { |
| 63 if (resumeCapability === void 0) | 63 if (resumeCapability === void 0) |
| 64 resumeCapability = null; | 64 resumeCapability = null; |
| 65 if (resumeCapability === null) | 65 if (resumeCapability == null) |
| 66 resumeCapability = new Capability(); | 66 resumeCapability = new Capability(); |
| 67 this[_pause](resumeCapability); | 67 this[_pause](resumeCapability); |
| 68 return resumeCapability; | 68 return resumeCapability; |
| 69 } | 69 } |
| 70 [_pause](resumeCapability) { | 70 [_pause](resumeCapability) { |
| 71 let message = new core.List(3); | 71 let message = new core.List(3); |
| 72 dart.dsetindex(message, 0, "pause"); | 72 dart.dsetindex(message, 0, "pause"); |
| 73 dart.dsetindex(message, 1, this.pauseCapability); | 73 dart.dsetindex(message, 1, this.pauseCapability); |
| 74 dart.dsetindex(message, 2, resumeCapability); | 74 dart.dsetindex(message, 2, resumeCapability); |
| 75 this.controlPort.send(message); | 75 this.controlPort.send(message); |
| (...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 203 } | 203 } |
| 204 // Exports: | 204 // Exports: |
| 205 exports.Capability = Capability; | 205 exports.Capability = Capability; |
| 206 exports.IsolateSpawnException = IsolateSpawnException; | 206 exports.IsolateSpawnException = IsolateSpawnException; |
| 207 exports.Isolate = Isolate; | 207 exports.Isolate = Isolate; |
| 208 exports.SendPort = SendPort; | 208 exports.SendPort = SendPort; |
| 209 exports.ReceivePort = ReceivePort; | 209 exports.ReceivePort = ReceivePort; |
| 210 exports.RawReceivePort = RawReceivePort; | 210 exports.RawReceivePort = RawReceivePort; |
| 211 exports.RemoteError = RemoteError; | 211 exports.RemoteError = RemoteError; |
| 212 })(isolate || (isolate = {})); | 212 })(isolate || (isolate = {})); |
| OLD | NEW |