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 1178 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1189 } | 1189 } |
1190 } | 1190 } |
1191 ['=='](other) { | 1191 ['=='](other) { |
1192 return dart.is(other, _WorkerSendPort) && dart.equals(this[_workerId], dar
t.dload(other, _workerId)) && dart.equals(this[_isolateId], dart.dload(other, _i
solateId)) && dart.equals(this[_receivePortId], dart.dload(other, _receivePortId
)); | 1192 return dart.is(other, _WorkerSendPort) && dart.equals(this[_workerId], dar
t.dload(other, _workerId)) && dart.equals(this[_isolateId], dart.dload(other, _i
solateId)) && dart.equals(this[_receivePortId], dart.dload(other, _receivePortId
)); |
1193 } | 1193 } |
1194 get hashCode() { | 1194 get hashCode() { |
1195 return dart.notNull(this[_workerId]) << 16 ^ dart.notNull(this[_isolateId]
) << 8 ^ dart.notNull(this[_receivePortId]); | 1195 return dart.notNull(this[_workerId]) << 16 ^ dart.notNull(this[_isolateId]
) << 8 ^ dart.notNull(this[_receivePortId]); |
1196 } | 1196 } |
1197 } | 1197 } |
1198 _WorkerSendPort[dart.implements] = () => [isolate.SendPort]; | 1198 _WorkerSendPort[dart.implements] = () => [isolate.SendPort]; |
| 1199 let _nextFreeId = Symbol('_nextFreeId'); |
1199 let _handler = Symbol('_handler'); | 1200 let _handler = Symbol('_handler'); |
1200 let _nextFreeId = Symbol('_nextFreeId'); | |
1201 class RawReceivePortImpl extends core.Object { | 1201 class RawReceivePortImpl extends core.Object { |
1202 RawReceivePortImpl(handler) { | 1202 RawReceivePortImpl(handler) { |
1203 this[_handler] = handler; | 1203 this[_handler] = handler; |
1204 this[_id] = (() => { | 1204 this[_id] = (() => { |
1205 let x = RawReceivePortImpl[_nextFreeId]; | 1205 let x = RawReceivePortImpl[_nextFreeId]; |
1206 RawReceivePortImpl[_nextFreeId] = dart.notNull(x) + 1; | 1206 RawReceivePortImpl[_nextFreeId] = dart.notNull(x) + 1; |
1207 return x; | 1207 return x; |
1208 })(); | 1208 })(); |
1209 this[_isClosed] = false; | 1209 this[_isClosed] = false; |
1210 exports._globalState.currentContext.register(this[_id], this); | 1210 exports._globalState.currentContext.register(this[_id], this); |
(...skipping 181 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1392 exports.leaveJsAsync = leaveJsAsync; | 1392 exports.leaveJsAsync = leaveJsAsync; |
1393 exports.isWorker = isWorker; | 1393 exports.isWorker = isWorker; |
1394 exports.startRootIsolate = startRootIsolate; | 1394 exports.startRootIsolate = startRootIsolate; |
1395 exports.IsolateNatives = IsolateNatives; | 1395 exports.IsolateNatives = IsolateNatives; |
1396 exports.RawReceivePortImpl = RawReceivePortImpl; | 1396 exports.RawReceivePortImpl = RawReceivePortImpl; |
1397 exports.ReceivePortImpl = ReceivePortImpl; | 1397 exports.ReceivePortImpl = ReceivePortImpl; |
1398 exports.TimerImpl = TimerImpl; | 1398 exports.TimerImpl = TimerImpl; |
1399 exports.hasTimer = hasTimer; | 1399 exports.hasTimer = hasTimer; |
1400 exports.CapabilityImpl = CapabilityImpl; | 1400 exports.CapabilityImpl = CapabilityImpl; |
1401 })(_isolate_helper || (_isolate_helper = {})); | 1401 })(_isolate_helper || (_isolate_helper = {})); |
OLD | NEW |