initial sync*, part of #221

lib/runtime/dart/_isolate_helper.js

 dart_library.library('dart/_isolate_helper', null, /* Imports */[
   "dart_runtime/dart",
   'dart/core',
   'dart/_interceptors',
   'dart/_js_helper',
   'dart/isolate',
   'dart/_foreign_helper',
   'dart/collection',
   'dart/async'
 ], /* Lazy imports */[
@@ skipping 484 matching lines @@
       }
     }
     [_nativeDetectEnvironment]() {
       let isWindowDefined = exports.globalWindow != null;
       let isWorkerDefined = exports.globalWorker != null;
       this.isWorker = !dart.notNull(isWindowDefined) && dart.notNull(exports.globalPostMessageDefined);
       this.supportsWorkers = dart.notNull(this.isWorker) || dart.notNull(isWorkerDefined) && IsolateNatives.thisScript != null;
       this.fromCommandLine = !dart.notNull(isWindowDefined) && !dart.notNull(this.isWorker);
     }
     [_nativeInitWorkerMessageHandler]() {
-      let func = function(f, a) {
+      let func = (function(f, a) {
         return function(e) {
           f(a, e);
         };
-      }(IsolateNatives._processWorkerMessage, this.mainManager);
+      })(IsolateNatives._processWorkerMessage, this.mainManager);
       self.onmessage = func;
-      self.dartPrint = self.dartPrint || function(serialize) {
+      self.dartPrint = self.dartPrint || (function(serialize) {
         return function(object) {
           if (self.console && self.console.log) {
             self.console.log(object);
           } else {
             self.postMessage(serialize(object));
           }
         };
-      }(_Manager._serializePrintMessage);
+      })(_Manager._serializePrintMessage);
     }
     static _serializePrintMessage(object) {
       return _serializeMessage(dart.map({command: "print", msg: object}));
     }
     maybeCloseWorker() {
       if (dart.notNull(this.isWorker) && dart.notNull(this.isolates.isEmpty) && this.topEventLoop[_activeJsAsyncCount] == 0) {
         this.mainManager.postMessage(_serializeMessage(dart.map({command: 'close'})));
       }
     }
   }
@@ skipping 74 matching lines @@
     setErrorsFatal(authentification, errorsAreFatal) {
       if (!dart.equals(this.terminateCapability, authentification))
         return;
       this.errorsAreFatal = errorsAreFatal;
     }
     handlePing(responsePort, pingType) {
       if (pingType == isolate.Isolate.IMMEDIATE || pingType == isolate.Isolate.BEFORE_NEXT_EVENT && !dart.notNull(this[_isExecutingEvent])) {
         responsePort.send(null);
         return;
       }
-      let respond = () => {
+      function respond() {
         responsePort.send(null);
-      };
+      }
       dart.fn(respond, dart.void, []);
       if (pingType == isolate.Isolate.AS_EVENT) {
         exports._globalState.topEventLoop.enqueue(this, respond, "ping");
         return;
       }
       dart.assert(pingType == isolate.Isolate.BEFORE_NEXT_EVENT);
       if (this[_scheduledControlEvents] == null) {
         this[_scheduledControlEvents] = collection.Queue.new();
       }
       dart.dsend(this[_scheduledControlEvents], 'addLast', respond);
@@ skipping 226 matching lines @@
       if (event == null) {
         this.checkOpenReceivePortsFromCommandLine();
         exports._globalState.maybeCloseWorker();
         return false;
       }
       event.process();
       return true;
     }
     [_runHelper]() {
       if (exports.globalWindow != null) {
-        let next = () => {
+        let next = (function() {
           if (!dart.notNull(this.runIteration()))
             return;
           async.Timer.run(next);
-        };
+        }).bind(this);
         dart.fn(next);
         next();
       } else {
         while (dart.notNull(this.runIteration())) {
         }
       }
     }
     run() {
       if (!dart.notNull(exports._globalState.isWorker)) {
         this[_runHelper]();
@@ skipping 78 matching lines @@
     }
     static computeThisScriptJsshell() {
       return dart.as(thisFilename(), core.String);
     }
     static computeThisScriptD8() {
       return IsolateNatives.computeThisScriptFromTrace();
     }
     static computeThisScriptFromTrace() {
       let stack = new Error().stack;
       if (stack == null) {
-        stack = function() {
+        stack = (function() {
           try {
             throw new Error();
           } catch (e) {
             return e.stack;
           }
 
-        }();
+        })();
         if (stack == null)
           throw new core.UnsupportedError('No stack trace');
       }
       let pattern = null, matches = null;
       pattern = new RegExp("^ *at [^(]*\\((.*):[0-9]*:[0-9]*\\)$", "m");
       matches = stack.match(pattern);
       if (matches != null)
         return matches[1];
       pattern = new RegExp("^[^@]*@(.*):[0-9]*$", "m");
       matches = stack.match(pattern);
@@ skipping 161 matching lines @@
       }), 'nonworker start');
     }
     static get currentIsolate() {
       let context = dart.as(_foreign_helper.JS_CURRENT_ISOLATE_CONTEXT(), _IsolateContext);
       return new isolate.Isolate(context.controlPort.sendPort, {pauseCapability: context.pauseCapability, terminateCapability: context.terminateCapability});
     }
     static _startIsolate(topLevel, args, message, isSpawnUri, startPaused, replyTo) {
       let context = dart.as(_foreign_helper.JS_CURRENT_ISOLATE_CONTEXT(), _IsolateContext);
       _js_helper.Primitives.initializeStatics(context.id);
       replyTo.send([_SPAWNED_SIGNAL, context.controlPort.sendPort, context.pauseCapability, context.terminateCapability]);
-      let runStartFunction = () => {
+      function runStartFunction() {
         context.initialized = true;
         if (!dart.notNull(isSpawnUri)) {
           dart.dcall(topLevel, message);
         } else if (dart.is(topLevel, _MainFunctionArgsMessage)) {
           dart.dcall(topLevel, args, message);
         } else if (dart.is(topLevel, _MainFunctionArgs)) {
           dart.dcall(topLevel, args);
         } else {
           dart.dcall(topLevel);
         }
-      };
+      }
       dart.fn(runStartFunction, dart.void, []);
       if (dart.notNull(startPaused)) {
         context.addPause(context.pauseCapability, context.pauseCapability);
         exports._globalState.topEventLoop.enqueue(context, runStartFunction, 'start isolate');
       } else {
         runStartFunction();
       }
     }
     static _spawnWorker(functionName, uri, args, message, isSpawnUri, startPaused, replyPort, onError) {
       if (uri == null)
         uri = IsolateNatives.thisScript;
       let worker = new Worker(uri);
-      let onerrorTrampoline = function(f, u, c) {
+      let onerrorTrampoline = (function(f, u, c) {
         return function(e) {
           return f(e, u, c);
         };
-      }(IsolateNatives.workerOnError, uri, onError);
+      })(IsolateNatives.workerOnError, uri, onError);
       worker.onerror = onerrorTrampoline;
-      let processWorkerMessageTrampoline = function(f, a) {
+      let processWorkerMessageTrampoline = (function(f, a) {
         return function(e) {
           e.onerror = null;
           return f(a, e);
         };
-      }(IsolateNatives._processWorkerMessage, worker);
+      })(IsolateNatives._processWorkerMessage, worker);
       worker.onmessage = processWorkerMessageTrampoline;
       let o = exports._globalState;
       let workerId = o.nextManagerId;
       o.nextManagerId = dart.notNull(workerId) + 1;
       IsolateNatives.workerIds.set(worker, workerId);
       exports._globalState.managers.set(workerId, worker);
       worker.postMessage(_serializeMessage(dart.map({command: 'start', id: workerId, replyTo: _serializeMessage(replyPort), args: args, msg: _serializeMessage(message), isSpawnUri: isSpawnUri, startPaused: startPaused, functionName: functionName})));
     }
     static workerOnError(event, uri, onError) {
       event.preventDefault();
@@ skipping 235 matching lines @@
   });
   let _once = Symbol('_once');
   let _inEventLoop = Symbol('_inEventLoop');
   let _handle = Symbol('_handle');
   class TimerImpl extends core.Object {
     TimerImpl(milliseconds, callback) {
       this[_once] = true;
       this[_inEventLoop] = false;
       this[_handle] = null;
       if (milliseconds == 0 && (!dart.notNull(hasTimer()) || dart.notNull(exports._globalState.isWorker))) {
-        let internalCallback = () => {
+        let internalCallback = (function() {
           this[_handle] = null;
           callback();
-        };
+        }).bind(this);
         dart.fn(internalCallback, dart.void, []);
         this[_handle] = 1;
         exports._globalState.topEventLoop.enqueue(exports._globalState.currentContext, internalCallback, 'timer');
         this[_inEventLoop] = true;
       } else if (dart.notNull(hasTimer())) {
-        let internalCallback = () => {
+        let internalCallback = (function() {
           this[_handle] = null;
           leaveJsAsync();
           callback();
-        };
+        }).bind(this);
         dart.fn(internalCallback, dart.void, []);
         enterJsAsync();
         this[_handle] = self.setTimeout(internalCallback, milliseconds);
       } else {
         dart.assert(dart.notNull(milliseconds) > 0);
         throw new core.UnsupportedError("Timer greater than 0.");
       }
     }
     periodic(milliseconds, callback) {
       this[_once] = false;
@@ skipping 84 matching lines @@
   exports.leaveJsAsync = leaveJsAsync;
   exports.isWorker = isWorker;
   exports.startRootIsolate = startRootIsolate;
   exports.IsolateNatives = IsolateNatives;
   exports.RawReceivePortImpl = RawReceivePortImpl;
   exports.ReceivePortImpl = ReceivePortImpl;
   exports.TimerImpl = TimerImpl;
   exports.hasTimer = hasTimer;
   exports.CapabilityImpl = CapabilityImpl;
 });