| 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 934 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 945 break; | 945 break; |
| 946 } | 946 } |
| 947 case 'error': | 947 case 'error': |
| 948 { | 948 { |
| 949 throw dart.dindex(msg, 'msg'); | 949 throw dart.dindex(msg, 'msg'); |
| 950 } | 950 } |
| 951 } | 951 } |
| 952 } | 952 } |
| 953 static handleSpawnWorkerRequest(msg) { | 953 static handleSpawnWorkerRequest(msg) { |
| 954 let replyPort = dart.dindex(msg, 'replyPort'); | 954 let replyPort = dart.dindex(msg, 'replyPort'); |
| 955 IsolateNatives.spawn(dart.as(dart.dindex(msg, 'functionName'), core.String
), dart.as(dart.dindex(msg, 'uri'), core.String), dart.as(dart.dindex(msg, 'args
'), core.List$(core.String)), dart.dindex(msg, 'msg'), false, dart.as(dart.dinde
x(msg, 'isSpawnUri'), core.bool), dart.as(dart.dindex(msg, 'startPaused'), core.
bool)).then(dart.closureWrap((msg) => { | 955 IsolateNatives.spawn(dart.as(dart.dindex(msg, 'functionName'), core.String
), dart.as(dart.dindex(msg, 'uri'), core.String), dart.as(dart.dindex(msg, 'args
'), core.List$(core.String)), dart.dindex(msg, 'msg'), false, dart.as(dart.dinde
x(msg, 'isSpawnUri'), core.bool), dart.as(dart.dindex(msg, 'startPaused'), core.
bool)).then(dart.as((msg) => { |
| 956 dart.dinvoke(replyPort, 'send', msg); | 956 dart.dinvoke(replyPort, 'send', msg); |
| 957 }, "(List<dynamic>) → dynamic"), { | 957 }, dart.throw_("Unimplemented type (List<dynamic>) → dynamic")), { |
| 958 onError: (errorMessage) => { | 958 onError: (errorMessage) => { |
| 959 dart.dinvoke(replyPort, 'send', new core.List.from([_SPAWN_FAILED_SIGN
AL, errorMessage])); | 959 dart.dinvoke(replyPort, 'send', new core.List.from([_SPAWN_FAILED_SIGN
AL, errorMessage])); |
| 960 } | 960 } |
| 961 }); | 961 }); |
| 962 } | 962 } |
| 963 static [_log](msg) { | 963 static [_log](msg) { |
| 964 if (exports._globalState.isWorker) { | 964 if (exports._globalState.isWorker) { |
| 965 exports._globalState.mainManager.postMessage(_serializeMessage(dart.map(
{command: 'log', msg: msg}))); | 965 exports._globalState.mainManager.postMessage(_serializeMessage(dart.map(
{command: 'log', msg: msg}))); |
| 966 } else { | 966 } else { |
| 967 try { | 967 try { |
| (...skipping 407 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1375 exports.leaveJsAsync = leaveJsAsync; | 1375 exports.leaveJsAsync = leaveJsAsync; |
| 1376 exports.isWorker = isWorker; | 1376 exports.isWorker = isWorker; |
| 1377 exports.startRootIsolate = startRootIsolate; | 1377 exports.startRootIsolate = startRootIsolate; |
| 1378 exports.IsolateNatives = IsolateNatives; | 1378 exports.IsolateNatives = IsolateNatives; |
| 1379 exports.RawReceivePortImpl = RawReceivePortImpl; | 1379 exports.RawReceivePortImpl = RawReceivePortImpl; |
| 1380 exports.ReceivePortImpl = ReceivePortImpl; | 1380 exports.ReceivePortImpl = ReceivePortImpl; |
| 1381 exports.TimerImpl = TimerImpl; | 1381 exports.TimerImpl = TimerImpl; |
| 1382 exports.hasTimer = hasTimer; | 1382 exports.hasTimer = hasTimer; |
| 1383 exports.CapabilityImpl = CapabilityImpl; | 1383 exports.CapabilityImpl = CapabilityImpl; |
| 1384 })(_isolate_helper || (_isolate_helper = {})); | 1384 })(_isolate_helper || (_isolate_helper = {})); |
| OLD | NEW |