| 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 692 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 703 exports._globalState.isolates.set(this.id, this); | 703 exports._globalState.isolates.set(this.id, this); |
| 704 } else { | 704 } else { |
| 705 this.kill(); | 705 this.kill(); |
| 706 } | 706 } |
| 707 } | 707 } |
| 708 kill() { | 708 kill() { |
| 709 if (this[_scheduledControlEvents] != null) { | 709 if (this[_scheduledControlEvents] != null) { |
| 710 dart.dinvoke(this[_scheduledControlEvents], 'clear'); | 710 dart.dinvoke(this[_scheduledControlEvents], 'clear'); |
| 711 } | 711 } |
| 712 for (let port of this.ports.values) { | 712 for (let port of this.ports.values) { |
| 713 dart.dinvoke(port, '_close'); | 713 port._close(); |
| 714 } | 714 } |
| 715 this.ports.clear(); | 715 this.ports.clear(); |
| 716 this.weakPorts.clear(); | 716 this.weakPorts.clear(); |
| 717 exports._globalState.isolates.remove(this.id); | 717 exports._globalState.isolates.remove(this.id); |
| 718 this.errorPorts.clear(); | 718 this.errorPorts.clear(); |
| 719 if (this.doneHandlers != null) { | 719 if (this.doneHandlers != null) { |
| 720 for (let port of this.doneHandlers) { | 720 for (let port of dart.as(this.doneHandlers, core.Iterable$(isolate.SendP
ort))) { |
| 721 port.send(null); | 721 port.send(null); |
| 722 } | 722 } |
| 723 this.doneHandlers = null; | 723 this.doneHandlers = null; |
| 724 } | 724 } |
| 725 } | 725 } |
| 726 unregister(portId) { | 726 unregister(portId) { |
| 727 this.ports.remove(portId); | 727 this.ports.remove(portId); |
| 728 this.weakPorts.remove(portId); | 728 this.weakPorts.remove(portId); |
| 729 this[_updateGlobalState](); | 729 this[_updateGlobalState](); |
| 730 } | 730 } |
| (...skipping 641 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1372 exports.leaveJsAsync = leaveJsAsync; | 1372 exports.leaveJsAsync = leaveJsAsync; |
| 1373 exports.isWorker = isWorker; | 1373 exports.isWorker = isWorker; |
| 1374 exports.startRootIsolate = startRootIsolate; | 1374 exports.startRootIsolate = startRootIsolate; |
| 1375 exports.IsolateNatives = IsolateNatives; | 1375 exports.IsolateNatives = IsolateNatives; |
| 1376 exports.RawReceivePortImpl = RawReceivePortImpl; | 1376 exports.RawReceivePortImpl = RawReceivePortImpl; |
| 1377 exports.ReceivePortImpl = ReceivePortImpl; | 1377 exports.ReceivePortImpl = ReceivePortImpl; |
| 1378 exports.TimerImpl = TimerImpl; | 1378 exports.TimerImpl = TimerImpl; |
| 1379 exports.hasTimer = hasTimer; | 1379 exports.hasTimer = hasTimer; |
| 1380 exports.CapabilityImpl = CapabilityImpl; | 1380 exports.CapabilityImpl = CapabilityImpl; |
| 1381 })(_isolate_helper || (_isolate_helper = {})); | 1381 })(_isolate_helper || (_isolate_helper = {})); |
| OLD | NEW |