| Index: test/codegen/expect/language/await_for_cancel_test.js | 
| diff --git a/test/codegen/expect/language/await_for_cancel_test.js b/test/codegen/expect/language/await_for_cancel_test.js | 
| new file mode 100644 | 
| index 0000000000000000000000000000000000000000..64633163b01a0881c717a64969c8c8723488fe2e | 
| --- /dev/null | 
| +++ b/test/codegen/expect/language/await_for_cancel_test.js | 
| @@ -0,0 +1,117 @@ | 
| +dart_library.library('language/await_for_cancel_test', null, /* Imports */[ | 
| +  'dart_sdk', | 
| +  'expect', | 
| +  'async_helper' | 
| +], function load__await_for_cancel_test(exports, dart_sdk, expect, async_helper) { | 
| +  'use strict'; | 
| +  const core = dart_sdk.core; | 
| +  const async = dart_sdk.async; | 
| +  const dart = dart_sdk.dart; | 
| +  const dartx = dart_sdk.dartx; | 
| +  const expect$ = expect.expect; | 
| +  const async_helper$ = async_helper.async_helper; | 
| +  const await_for_cancel_test = Object.create(null); | 
| +  let VoidTodynamic = () => (VoidTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [])))(); | 
| +  let dynamicTodynamic = () => (dynamicTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [dart.dynamic])))(); | 
| +  let VoidTovoid = () => (VoidTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [])))(); | 
| +  let VoidToStreamController = () => (VoidToStreamController = dart.constFn(dart.definiteFunctionType(async.StreamController, [])))(); | 
| +  await_for_cancel_test.canceled = null; | 
| +  await_for_cancel_test.test1 = function() { | 
| +    return dart.async(function*() { | 
| +      await_for_cancel_test.canceled = false; | 
| +      try { | 
| +        let controller = await_for_cancel_test.infiniteStreamController(); | 
| +        outer: | 
| +          while (true) { | 
| +            let it = async.StreamIterator.new(controller.stream); | 
| +            try { | 
| +              while (yield it.moveNext()) { | 
| +                let x = it.current; | 
| +                for (let j = 0; j < 10; j++) { | 
| +                  if (j == 5) break outer; | 
| +                } | 
| +              } | 
| +            } finally { | 
| +              yield it.cancel(); | 
| +            } | 
| +          } | 
| +      } finally { | 
| +        expect$.Expect.isTrue(await_for_cancel_test.canceled); | 
| +      } | 
| +    }, dart.dynamic); | 
| +  }; | 
| +  dart.fn(await_for_cancel_test.test1, VoidTodynamic()); | 
| +  await_for_cancel_test.test2 = function() { | 
| +    return dart.async(function*() { | 
| +      await_for_cancel_test.canceled = false; | 
| +      try { | 
| +        let controller = await_for_cancel_test.infiniteStreamController(); | 
| +        let first = true; | 
| +        outer: | 
| +          while (true) { | 
| +            if (first) { | 
| +              first = false; | 
| +            } else { | 
| +              break; | 
| +            } | 
| +            let it = async.StreamIterator.new(controller.stream); | 
| +            try { | 
| +              while (yield it.moveNext()) { | 
| +                let x = it.current; | 
| +                for (let j = 0; j < 10; j++) { | 
| +                  if (j == 5) continue outer; | 
| +                } | 
| +              } | 
| +            } finally { | 
| +              yield it.cancel(); | 
| +            } | 
| +          } | 
| +      } finally { | 
| +        expect$.Expect.isTrue(await_for_cancel_test.canceled); | 
| +      } | 
| +    }, dart.dynamic); | 
| +  }; | 
| +  dart.fn(await_for_cancel_test.test2, VoidTodynamic()); | 
| +  await_for_cancel_test.test = function() { | 
| +    return dart.async(function*() { | 
| +      yield await_for_cancel_test.test1(); | 
| +      yield await_for_cancel_test.test2(); | 
| +    }, dart.dynamic); | 
| +  }; | 
| +  dart.fn(await_for_cancel_test.test, VoidTodynamic()); | 
| +  await_for_cancel_test.main = function() { | 
| +    async_helper$.asyncStart(); | 
| +    dart.dsend(await_for_cancel_test.test(), 'then', dart.fn(_ => { | 
| +      async_helper$.asyncEnd(); | 
| +    }, dynamicTodynamic())); | 
| +  }; | 
| +  dart.fn(await_for_cancel_test.main, VoidTodynamic()); | 
| +  await_for_cancel_test.infiniteStreamController = function() { | 
| +    let controller = null; | 
| +    let timer = null; | 
| +    let counter = 0; | 
| +    function tick() { | 
| +      if (dart.test(controller.isPaused)) { | 
| +        return; | 
| +      } | 
| +      if (dart.test(await_for_cancel_test.canceled)) { | 
| +        return; | 
| +      } | 
| +      counter++; | 
| +      controller.add(counter); | 
| +      async.Timer.run(tick); | 
| +    } | 
| +    dart.fn(tick, VoidTovoid()); | 
| +    function startTimer() { | 
| +      async.Timer.run(tick); | 
| +    } | 
| +    dart.fn(startTimer, VoidTovoid()); | 
| +    controller = async.StreamController.new({onListen: startTimer, onResume: startTimer, onCancel: dart.fn(() => { | 
| +        await_for_cancel_test.canceled = true; | 
| +      }, VoidTodynamic())}); | 
| +    return controller; | 
| +  }; | 
| +  dart.fn(await_for_cancel_test.infiniteStreamController, VoidToStreamController()); | 
| +  // Exports: | 
| +  exports.await_for_cancel_test = await_for_cancel_test; | 
| +}); | 
|  |