| OLD | NEW |
| 1 var _isolate_helper; | 1 var _isolate_helper; |
| 2 (function(exports) { | 2 (function(exports) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 // Function _serializeMessage: (dynamic) → dynamic | 4 // Function _serializeMessage: (dynamic) → dynamic |
| 5 function _serializeMessage(message) { | 5 function _serializeMessage(message) { |
| 6 return new _Serializer().serialize(message); | 6 return new _Serializer().serialize(message); |
| 7 } | 7 } |
| 8 // Function _deserializeMessage: (dynamic) → dynamic | 8 // Function _deserializeMessage: (dynamic) → dynamic |
| 9 function _deserializeMessage(message) { | 9 function _deserializeMessage(message) { |
| 10 return new _Deserializer().deserialize(message); | 10 return new _Deserializer().deserialize(message); |
| (...skipping 691 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 702 exports._globalState.isolates.set(this.id, this); | 702 exports._globalState.isolates.set(this.id, this); |
| 703 } else { | 703 } else { |
| 704 this.kill(); | 704 this.kill(); |
| 705 } | 705 } |
| 706 } | 706 } |
| 707 kill() { | 707 kill() { |
| 708 if (this[_scheduledControlEvents] !== null) { | 708 if (this[_scheduledControlEvents] !== null) { |
| 709 dart.dinvoke(this[_scheduledControlEvents], 'clear'); | 709 dart.dinvoke(this[_scheduledControlEvents], 'clear'); |
| 710 } | 710 } |
| 711 for (let port of this.ports.values) { | 711 for (let port of this.ports.values) { |
| 712 dart.dinvoke(port, '_close'); | 712 port._close(); |
| 713 } | 713 } |
| 714 this.ports.clear(); | 714 this.ports.clear(); |
| 715 this.weakPorts.clear(); | 715 this.weakPorts.clear(); |
| 716 exports._globalState.isolates.remove(this.id); | 716 exports._globalState.isolates.remove(this.id); |
| 717 this.errorPorts.clear(); | 717 this.errorPorts.clear(); |
| 718 if (this.doneHandlers !== null) { | 718 if (this.doneHandlers !== null) { |
| 719 for (let port of this.doneHandlers) { | 719 for (let port of dart.as(this.doneHandlers, core.Iterable$(isolate.SendP
ort))) { |
| 720 port.send(null); | 720 port.send(null); |
| 721 } | 721 } |
| 722 this.doneHandlers = null; | 722 this.doneHandlers = null; |
| 723 } | 723 } |
| 724 } | 724 } |
| 725 unregister(portId) { | 725 unregister(portId) { |
| 726 this.ports.remove(portId); | 726 this.ports.remove(portId); |
| 727 this.weakPorts.remove(portId); | 727 this.weakPorts.remove(portId); |
| 728 this[_updateGlobalState](); | 728 this[_updateGlobalState](); |
| 729 } | 729 } |
| (...skipping 634 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1364 exports.leaveJsAsync = leaveJsAsync; | 1364 exports.leaveJsAsync = leaveJsAsync; |
| 1365 exports.isWorker = isWorker; | 1365 exports.isWorker = isWorker; |
| 1366 exports.startRootIsolate = startRootIsolate; | 1366 exports.startRootIsolate = startRootIsolate; |
| 1367 exports.IsolateNatives = IsolateNatives; | 1367 exports.IsolateNatives = IsolateNatives; |
| 1368 exports.RawReceivePortImpl = RawReceivePortImpl; | 1368 exports.RawReceivePortImpl = RawReceivePortImpl; |
| 1369 exports.ReceivePortImpl = ReceivePortImpl; | 1369 exports.ReceivePortImpl = ReceivePortImpl; |
| 1370 exports.TimerImpl = TimerImpl; | 1370 exports.TimerImpl = TimerImpl; |
| 1371 exports.hasTimer = hasTimer; | 1371 exports.hasTimer = hasTimer; |
| 1372 exports.CapabilityImpl = CapabilityImpl; | 1372 exports.CapabilityImpl = CapabilityImpl; |
| 1373 })(_isolate_helper || (_isolate_helper = {})); | 1373 })(_isolate_helper || (_isolate_helper = {})); |
| OLD | NEW |