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 |