Mark recursive_inheritance_test as passing

test/codegen_expected/language/async_star_test_03_multi.js

 dart_library.library('language/async_star_test_03_multi', null, /* Imports */[
   'dart_sdk',
   'unittest'
 ], function load__async_star_test_03_multi(exports, dart_sdk, unittest) {
   'use strict';
   const core = dart_sdk.core;
+  const async = dart_sdk.async;
   const _interceptors = dart_sdk._interceptors;
-  const async = dart_sdk.async;
   const dart = dart_sdk.dart;
   const dartx = dart_sdk.dartx;
   const unittest$ = unittest.unittest;
   const src__matcher__expect = unittest.src__matcher__expect;
   const src__matcher__core_matchers = unittest.src__matcher__core_matchers;
   const src__matcher__numeric_matchers = unittest.src__matcher__numeric_matchers;
   const async_star_test_03_multi = Object.create(null);
+  let StreamOfint = () => (StreamOfint = dart.constFn(async.Stream$(core.int)))();
   let JSArrayOfint = () => (JSArrayOfint = dart.constFn(_interceptors.JSArray$(core.int)))();
+  let ListOfint = () => (ListOfint = dart.constFn(core.List$(core.int)))();
   let JSArrayOfObject = () => (JSArrayOfObject = dart.constFn(_interceptors.JSArray$(core.Object)))();
-  let StreamOfint = () => (StreamOfint = dart.constFn(async.Stream$(core.int)))();
+  let VoidToObject = () => (VoidToObject = dart.constFn(dart.functionType(core.Object, [])))();
+  let StreamOfVoidToObject = () => (StreamOfVoidToObject = dart.constFn(async.Stream$(VoidToObject())))();
   let FutureOfObject = () => (FutureOfObject = dart.constFn(async.Future$(core.Object)))();
+  let VoidToFutureOfObject = () => (VoidToFutureOfObject = dart.constFn(dart.functionType(FutureOfObject(), [])))();
+  let StreamOfVoidToFutureOfObject = () => (StreamOfVoidToFutureOfObject = dart.constFn(async.Stream$(VoidToFutureOfObject())))();
   let StreamOfObject = () => (StreamOfObject = dart.constFn(async.Stream$(core.Object)))();
+  let VoidToStreamOfObject = () => (VoidToStreamOfObject = dart.constFn(dart.functionType(StreamOfObject(), [])))();
+  let StreamOfVoidToStreamOfObject = () => (StreamOfVoidToStreamOfObject = dart.constFn(async.Stream$(VoidToStreamOfObject())))();
   let JSArrayOfString = () => (JSArrayOfString = dart.constFn(_interceptors.JSArray$(core.String)))();
+  let StreamOfvoid = () => (StreamOfvoid = dart.constFn(async.Stream$(dart.void)))();
+  let FutureOfint = () => (FutureOfint = dart.constFn(async.Future$(core.int)))();
+  let StreamOfnum = () => (StreamOfnum = dart.constFn(async.Stream$(core.num)))();
+  let VoidToStream = () => (VoidToStream = dart.constFn(dart.definiteFunctionType(async.Stream, [])))();
+  let ListTodynamic = () => (ListTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [core.List])))();
+  let VoidToFuture = () => (VoidToFuture = dart.constFn(dart.definiteFunctionType(async.Future, [])))();
+  let VoidToStreamOfint = () => (VoidToStreamOfint = dart.constFn(dart.definiteFunctionType(StreamOfint(), [])))();
+  let ListOfintTodynamic = () => (ListOfintTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [ListOfint()])))();
+  let intTovoid = () => (intTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [core.int])))();
   let VoidTodynamic = () => (VoidTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [])))();
+  let dynamicTovoid = () => (dynamicTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [dart.dynamic])))();
+  let dynamicToStream = () => (dynamicToStream = dart.constFn(dart.definiteFunctionType(async.Stream, [dart.dynamic])))();
   let dynamicTodynamic = () => (dynamicTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [dart.dynamic])))();
-  let dynamicTovoid = () => (dynamicTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [dart.dynamic])))();
-  let VoidToFuture = () => (VoidToFuture = dart.constFn(dart.definiteFunctionType(async.Future, [])))();
   let VoidTovoid = () => (VoidTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [])))();
-  let VoidToObject = () => (VoidToObject = dart.constFn(dart.definiteFunctionType(core.Object, [])))();
-  let VoidToFutureOfObject = () => (VoidToFutureOfObject = dart.constFn(dart.definiteFunctionType(FutureOfObject(), [])))();
-  let VoidToStreamOfObject = () => (VoidToStreamOfObject = dart.constFn(dart.definiteFunctionType(StreamOfObject(), [])))();
+  let dynamicToStreamOfint = () => (dynamicToStreamOfint = dart.constFn(dart.definiteFunctionType(StreamOfint(), [dart.dynamic])))();
+  let VoidToint = () => (VoidToint = dart.constFn(dart.definiteFunctionType(core.int, [])))();
+  let VoidToObject$ = () => (VoidToObject$ = dart.constFn(dart.definiteFunctionType(core.Object, [])))();
+  let VoidToStreamOfVoidToObject = () => (VoidToStreamOfVoidToObject = dart.constFn(dart.definiteFunctionType(StreamOfVoidToObject(), [])))();
+  let FnTodynamic = () => (FnTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [VoidToObject()])))();
+  let VoidToFutureOfObject$ = () => (VoidToFutureOfObject$ = dart.constFn(dart.definiteFunctionType(FutureOfObject(), [])))();
+  let VoidToStreamOfVoidToFutureOfObject = () => (VoidToStreamOfVoidToFutureOfObject = dart.constFn(dart.definiteFunctionType(StreamOfVoidToFutureOfObject(), [])))();
+  let ObjectTodynamic = () => (ObjectTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [core.Object])))();
+  let FnToFutureOfObject = () => (FnToFutureOfObject = dart.constFn(dart.definiteFunctionType(FutureOfObject(), [VoidToFutureOfObject()])))();
+  let VoidToStreamOfObject$ = () => (VoidToStreamOfObject$ = dart.constFn(dart.definiteFunctionType(StreamOfObject(), [])))();
+  let VoidToStreamOfVoidToStreamOfObject = () => (VoidToStreamOfVoidToStreamOfObject = dart.constFn(dart.definiteFunctionType(StreamOfVoidToStreamOfObject(), [])))();
+  let FnToFutureOfObject$ = () => (FnToFutureOfObject$ = dart.constFn(dart.definiteFunctionType(FutureOfObject(), [VoidToStreamOfObject()])))();
+  let VoidToStreamOfvoid = () => (VoidToStreamOfvoid = dart.constFn(dart.definiteFunctionType(StreamOfvoid(), [])))();
+  let voidTovoid = () => (voidTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [dart.void])))();
   let dynamicToFuture = () => (dynamicToFuture = dart.constFn(dart.definiteFunctionType(async.Future, [dart.dynamic])))();
-  let VoidToint = () => (VoidToint = dart.constFn(dart.definiteFunctionType(core.int, [])))();
+  let intToStreamOfint = () => (intToStreamOfint = dart.constFn(dart.definiteFunctionType(StreamOfint(), [core.int])))();
+  let dynamicToFutureOfint = () => (dynamicToFutureOfint = dart.constFn(dart.definiteFunctionType(FutureOfint(), [dart.dynamic])))();
   let intTodynamic = () => (intTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [core.int])))();
+  let dynamicToStreamOfnum = () => (dynamicToStreamOfnum = dart.constFn(dart.definiteFunctionType(StreamOfnum(), [dart.dynamic])))();
+  let VoidToFutureOfint = () => (VoidToFutureOfint = dart.constFn(dart.definiteFunctionType(FutureOfint(), [])))();
   let dynamicAnddynamicTodynamic = () => (dynamicAnddynamicTodynamic = dart.constFn(dart.definiteFunctionType(dart.dynamic, [dart.dynamic, dart.dynamic])))();
   let dynamicAndEventSinkTovoid = () => (dynamicAndEventSinkTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [dart.dynamic, async.EventSink])))();
   let ObjectAndStackTraceAndEventSinkTovoid = () => (ObjectAndStackTraceAndEventSinkTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [core.Object, core.StackTrace, async.EventSink])))();
   let EventSinkTovoid = () => (EventSinkTovoid = dart.constFn(dart.definiteFunctionType(dart.void, [async.EventSink])))();
   async_star_test_03_multi.main = function() {
     unittest$.group("basic", dart.fn(() => {
       unittest$.test("empty", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
           }, dart.dynamic);
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dsend(f(), 'toList'), 'then', dart.fn(v => {
+        dart.fn(f, VoidToStream());
+        return f().toList().then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals([]));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, ListTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("single", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(42)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dsend(f(), 'toList'), 'then', dart.fn(v => {
+        dart.fn(f, VoidToStreamOfint());
+        return f().toList().then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals(JSArrayOfint().of([42])));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, ListOfintTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("call delays", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             list[dartx.add](1);
             if (stream.add(2)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        let res = dart.dsend(f(), 'forEach', dart.fn(x => list[dartx.add](x), dynamicTovoid()));
+        dart.fn(f, VoidToStreamOfint());
+        let res = f().forEach(dart.fn(x => list[dartx.add](x), intTovoid()));
         list[dartx.add](0);
-        return dart.dsend(res, 'whenComplete', dart.fn(() => {
+        return res.whenComplete(dart.fn(() => {
           src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([0, 1, 2])));
         }, VoidTodynamic()));
-      }, VoidTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("throws", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(1)) return;
             yield;
             dart.throw(2);
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         let completer = async.Completer.new();
         let list = [];
-        dart.dsend(f(), 'listen', dart.fn(x => list[dartx.add](x), dynamicTovoid()), {onError: dart.fn(v => list[dartx.add](dart.str`${v}`), dynamicTovoid()), onDone: dart.bind(completer, 'complete')});
+        f().listen(dart.fn(x => list[dartx.add](x), intTovoid()), {onError: dart.fn(v => list[dartx.add](dart.str`${v}`), dynamicTovoid()), onDone: dart.bind(completer, 'complete')});
         return completer.future.whenComplete(dart.fn(() => {
           src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfObject().of([1, "2"])));
         }, VoidTodynamic()));
       }, VoidToFuture()));
       unittest$.test("multiple", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 10; i++) {
               if (stream.add(i)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), core.List.generate(10, async_star_test_03_multi.id));
       }, VoidTodynamic()));
       unittest$.test("allows await", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = (yield async.Future.value(42));
             if (stream.add(x)) return;
             yield;
             x = (yield async.Future.value(42));
           }, dart.dynamic);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStream());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("allows await in loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 10; i++) {
               if (stream.add(yield i)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), core.List.generate(10, async_star_test_03_multi.id));
       }, VoidTodynamic()));
       unittest$.test("allows yield*", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.addStream(StreamOfint().fromIterable(JSArrayOfint().of([1, 2, 3])))) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([1, 2, 3]));
       }, VoidTodynamic()));
       unittest$.test("allows yield* of async*", dart.fn(() => {
         function f(n) {
           return dart.asyncStar(function*(stream, n) {
             if (stream.add(n)) return;
             yield;
             if (dart.equals(n, 0)) return;
             if (stream.addStream(async.Stream._check(f(dart.dsend(n, '-', 1))))) return;
             yield;
             if (stream.add(n)) return;
             yield;
           }, dart.dynamic, n);
         }
-        dart.fn(f, dynamicTodynamic());
+        dart.fn(f, dynamicToStream());
         return async_star_test_03_multi.expectList(f(3), JSArrayOfint().of([3, 2, 1, 0, 1, 2, 3]));
       }, VoidTodynamic()));
       unittest$.test("Cannot yield* non-stream", dart.fn(() => {
         function f(s) {
           return dart.asyncStar(function*(stream, s) {
             if (stream.addStream(async.Stream._check(s))) return;
             yield;
           }, dart.dynamic, s);
         }
-        dart.fn(f, dynamicTodynamic());
-        return dart.dsend(dart.dload(dart.dsend(f(42), 'transform', async_star_test_03_multi.getErrors), 'single'), 'then', dart.fn(v => {
+        dart.fn(f, dynamicToStream());
+        return f(42).transform(dart.dynamic)(async_star_test_03_multi.getErrors).single.then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(core.Error.is(v), src__matcher__core_matchers.isTrue);
         }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("Cannot yield* non-stream", dart.fn(() => {
         function f(s) {
           return dart.asyncStar(function*(stream, s) {
             if (stream.addStream(async.Stream._check(s))) return;
             yield;
           }, dart.dynamic, s);
         }
-        dart.fn(f, dynamicTodynamic());
-        return dart.dsend(dart.dload(dart.dsend(f(new async_star_test_03_multi.NotAStream()), 'transform', async_star_test_03_multi.getErrors), 'single'), 'then', dart.fn(v => {
+        dart.fn(f, dynamicToStream());
+        return f(new async_star_test_03_multi.NotAStream()).transform(dart.dynamic)(async_star_test_03_multi.getErrors).single.then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(core.Error.is(v), src__matcher__core_matchers.isTrue);
         }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+      }, VoidToFuture()));
     }, VoidTovoid()));
     unittest$.group("yield statement context", dart.fn(() => {
       unittest$.test("plain", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(0)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0]));
       }, VoidTodynamic()));
       unittest$.test("if-then-else", dart.fn(() => {
         function f(b) {
           return dart.asyncStar(function*(stream, b) {
             if (dart.test(b)) {
               if (stream.add(0)) return;
               yield;
             } else {
               if (stream.add(1)) return;
               yield;
             }
-          }, dart.dynamic, b);
+          }, core.int, b);
         }
-        dart.fn(f, dynamicTodynamic());
+        dart.fn(f, dynamicToStreamOfint());
         return dart.dsend(async_star_test_03_multi.expectList(f(true), JSArrayOfint().of([0])), 'whenComplete', dart.fn(() => {
           async_star_test_03_multi.expectList(f(false), JSArrayOfint().of([1]));
         }, VoidTodynamic()));
       }, VoidTodynamic()));
       unittest$.test("block", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(0)) return;
             yield;
             {
               if (stream.add(1)) return;
               yield;
             }
             if (stream.add(2)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("labeled", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             label1: {
               if (stream.add(0)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0]));
       }, VoidTodynamic()));
       unittest$.test("for-loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 3; i++) {
               if (stream.add(i)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("for-in-loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i of JSArrayOfint().of([0, 1, 2])) {
               if (stream.add(i)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("await for-in-loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let it = async.StreamIterator.new(StreamOfint().fromIterable(JSArrayOfint().of([0, 1, 2])));
             try {
               while (yield it.moveNext()) {
                 let i = it.current;
                 if (stream.add(i)) return;
                 yield;
               }
             } finally {
               yield it.cancel();
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("while-loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let i = 0;
             while (i < 3) {
               if (stream.add(i++)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("do-while-loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let i = 0;
             do {
               if (stream.add(i++)) return;
               yield;
             } while (i < 3);
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("try-catch-finally", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             try {
               if (stream.add(0)) return;
               yield;
             } catch (e) {
               if (stream.add(1)) return;
               yield;
             }
  finally {
               if (stream.add(2)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 2]));
       }, VoidTodynamic()));
       unittest$.test("try-catch-finally 2", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             try {
               if (stream.add(dart.throw(0))) return;
               yield;
             } catch (e) {
               if (stream.add(1)) return;
               yield;
             }
  finally {
               if (stream.add(2)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([1, 2]));
       }, VoidTodynamic()));
       unittest$.test("dead-code return", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             return;
             if (stream.add(1)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), []);
       }, VoidTodynamic()));
       unittest$.test("dead-code throw", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             try {
               dart.throw(0);
               if (stream.add(1)) return;
               yield;
             } catch (_) {
             }
 
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), []);
       }, VoidTodynamic()));
       unittest$.test("dead-code break", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             while (true) {
               break;
               if (stream.add(1)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), []);
       }, VoidTodynamic()));
       unittest$.test("dead-code break 2", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             label: {
               break label;
               if (stream.add(1)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), []);
       }, VoidTodynamic()));
       unittest$.test("dead-code continue", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             do {
               continue;
               if (stream.add(1)) return;
               yield;
             } while (false);
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), []);
       }, VoidTodynamic()));
     }, VoidTovoid()));
     unittest$.group("yield expressions", dart.fn(() => {
       unittest$.test("local variable", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 42;
             if (stream.add(x)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("constant variable", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 42;
             if (stream.add(x)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("function call", dart.fn(() => {
         function g() {
           return 42;
         }
-        dart.fn(g, VoidTodynamic());
+        dart.fn(g, VoidToint());
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(g())) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("unary operator", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = -42;
             if (stream.add(-x)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("binary operator", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 21;
             if (stream.add(x + x)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("ternary operator", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 21;
             if (stream.add(x == 21 ? x + x : x)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("suffix post-increment", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 42;
             if (stream.add(x++)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("suffix pre-increment", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 41;
             if (stream.add(++x)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("assignment", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 37;
             if (stream.add(x = 42)) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("assignment op", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = 41;
             if (stream.add((x = x + 1))) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("await", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(yield async.Future.value(42))) return;
             yield;
           }, dart.dynamic);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStream());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("index operator", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             let x = JSArrayOfint().of([42]);
             if (stream.add(x[dartx.get](0))) return;
             yield;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([42]));
       }, VoidTodynamic()));
       unittest$.test("function expression block", dart.fn(() => {
         let o = new core.Object();
         function f() {
           return dart.asyncStar(function*(stream) {
-            if (stream.add(dart.fn(() => o, VoidToObject()))) return;
+            if (stream.add(dart.fn(() => o, VoidToObject$()))) return;
             yield;
-          }, dart.dynamic);
+          }, VoidToObject());
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dload(f(), 'first'), 'then', dart.fn(v => {
-          src__matcher__expect.expect(dart.dcall(v), src__matcher__core_matchers.same(o));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        dart.fn(f, VoidToStreamOfVoidToObject());
+        return f().first.then(dart.dynamic)(dart.fn(v => {
+          src__matcher__expect.expect(v(), src__matcher__core_matchers.same(o));
+        }, FnTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("function expression arrow", dart.fn(() => {
         let o = new core.Object();
         function f() {
           return dart.asyncStar(function*(stream) {
-            if (stream.add(dart.fn(() => o, VoidToObject()))) return;
+            if (stream.add(dart.fn(() => o, VoidToObject$()))) return;
             yield;
-          }, dart.dynamic);
+          }, VoidToObject());
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dload(f(), 'first'), 'then', dart.fn(v => {
-          src__matcher__expect.expect(dart.dcall(v), src__matcher__core_matchers.same(o));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        dart.fn(f, VoidToStreamOfVoidToObject());
+        return f().first.then(dart.dynamic)(dart.fn(v => {
+          src__matcher__expect.expect(v(), src__matcher__core_matchers.same(o));
+        }, FnTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("function expression block async", dart.fn(() => {
         let o = new core.Object();
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(dart.fn(() => dart.async(function*() {
               return o;
-            }, core.Object), VoidToFutureOfObject()))) return;
+            }, core.Object), VoidToFutureOfObject$()))) return;
             yield;
-          }, dart.dynamic);
+          }, VoidToFutureOfObject());
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dsend(dart.dload(f(), 'first'), 'then', dart.fn(v => dart.dcall(v), dynamicTodynamic())), 'then', dart.fn(v => {
+        dart.fn(f, VoidToStreamOfVoidToFutureOfObject());
+        return f().first.then(FutureOfObject())(dart.fn(v => v(), FnToFutureOfObject())).then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.same(o));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, ObjectTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("function expression arrow async", dart.fn(() => {
         let o = new core.Object();
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(dart.fn(() => dart.async(function*() {
               return o;
-            }, core.Object), VoidToFutureOfObject()))) return;
+            }, core.Object), VoidToFutureOfObject$()))) return;
             yield;
-          }, dart.dynamic);
+          }, VoidToFutureOfObject());
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dsend(dart.dload(f(), 'first'), 'then', dart.fn(v => dart.dcall(v), dynamicTodynamic())), 'then', dart.fn(v => {
+        dart.fn(f, VoidToStreamOfVoidToFutureOfObject());
+        return f().first.then(FutureOfObject())(dart.fn(v => v(), FnToFutureOfObject())).then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.same(o));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, ObjectTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("function expression block async*", dart.fn(() => {
         let o = new core.Object();
         function f() {
           return dart.asyncStar(function*(stream) {
             if (stream.add(dart.fn(() => dart.asyncStar(function*(stream) {
               if (stream.add(o)) return;
               yield;
-            }, core.Object), VoidToStreamOfObject()))) return;
+            }, core.Object), VoidToStreamOfObject$()))) return;
             yield;
-          }, dart.dynamic);
+          }, VoidToStreamOfObject());
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dsend(dart.dload(f(), 'first'), 'then', dart.fn(v => dart.dload(dart.dcall(v), 'first'), dynamicTodynamic())), 'then', dart.fn(v => {
+        dart.fn(f, VoidToStreamOfVoidToStreamOfObject());
+        return f().first.then(FutureOfObject())(dart.fn(v => v().first, FnToFutureOfObject$())).then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.same(o));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, ObjectTodynamic()));
+      }, VoidToFuture()));
     }, VoidTovoid()));
     unittest$.group("loops", dart.fn(() => {
       unittest$.test("simple yield", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 3; i++) {
               if (stream.add(i)) return;
               yield;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
       unittest$.test("yield in double loop", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 3; i++) {
               for (let j = 0; j < 2; j++) {
                 if (stream.add(i * 2 + j)) return;
                 yield;
               }
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2, 3, 4, 5]));
       }, VoidTodynamic()));
       unittest$.test("yield in try body", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 3; i++) {
               try {
                 if (stream.add(i)) return;
                 yield;
               } finally {
                 list[dartx.add](dart.str`${i}`);
               }
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return dart.dsend(async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2])), 'whenComplete', dart.fn(() => {
           src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfString().of(["0", "1", "2"])));
         }, VoidTodynamic()));
       }, VoidTodynamic()));
       unittest$.test("yield in catch", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 3; i++) {
               try {
                 dart.throw(i);
               } catch (e) {
                 if (stream.add(e)) return;
                 yield;
               }
  finally {
                 list[dartx.add](dart.str`${i}`);
               }
             }
           }, dart.dynamic);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStream());
         return dart.dsend(async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2])), 'whenComplete', dart.fn(() => {
           src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfString().of(["0", "1", "2"])));
         }, VoidTodynamic()));
       }, VoidTodynamic()));
       unittest$.test("yield in finally", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 3; i++) {
               try {
                 dart.throw(i);
               } finally {
                 if (stream.add(i)) return;
                 yield;
                 list[dartx.add](dart.str`${i}`);
                 continue;
               }
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         return dart.dsend(async_star_test_03_multi.expectList(f(), JSArrayOfint().of([0, 1, 2])), 'whenComplete', dart.fn(() => {
           src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfString().of(["0", "1", "2"])));
         }, VoidTodynamic()));
       }, VoidTodynamic()));
       unittest$.test("keep yielding after cancel", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             for (let i = 0; i < 10; i++) {
               try {
                 if (stream.add(i)) return;
                 yield;
               } finally {
                 continue;
               }
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        return async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 3), JSArrayOfint().of([0, 1, 2]));
+        dart.fn(f, VoidToStreamOfint());
+        return async_star_test_03_multi.expectList(f().take(3), JSArrayOfint().of([0, 1, 2]));
       }, VoidTodynamic()));
     }, VoidTovoid()));
     unittest$.group("canceling", dart.fn(() => {
       unittest$.test("cancels at yield", dart.fn(() => {
         let exits = async.Completer.new();
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             try {
               list[dartx.add](0);
               if (stream.add(list[dartx.add](1))) return;
               yield;
               list[dartx.add](2);
             } finally {
               exits.complete(3);
             }
-          }, dart.dynamic);
+          }, dart.void);
         }
-        dart.fn(f, VoidTodynamic());
-        let subscription = dart.dsend(f(), 'listen', dart.fn(v => {
+        dart.fn(f, VoidToStreamOfvoid());
+        let subscription = f().listen(dart.fn(v => {
           src__matcher__expect.fail(dart.str`Received event ${v}`);
-        }, dynamicTodynamic()), {onDone: dart.fn(() => {
+        }, voidTovoid()), {onDone: dart.fn(() => {
             src__matcher__expect.fail("Received done");
-          }, VoidTodynamic())});
-        dart.dsend(subscription, 'cancel');
+          }, VoidTovoid())});
+        subscription.cancel();
         return exits.future.then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals(3));
           src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([0, 1])));
         }, dynamicTodynamic()));
       }, VoidToFuture()));
       unittest$.test("does cancel eventually", dart.fn(() => {
         let exits = async.Completer.new();
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             let i = 0;
             try {
               while (true) {
                 if (stream.add(i++)) return;
                 yield;
               }
             } finally {
               list[dartx.add]("a");
               exits.complete(i);
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(dart.dsend(async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 5), JSArrayOfint().of([0, 1, 2, 3, 4])), 'then', dart.fn(_ => exits.future, dynamicToFuture())), 'then', dart.fn(v => {
+        dart.fn(f, VoidToStreamOfint());
+        return dart.dsend(dart.dsend(async_star_test_03_multi.expectList(f().take(5), JSArrayOfint().of([0, 1, 2, 3, 4])), 'then', dart.fn(_ => exits.future, dynamicToFuture())), 'then', dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__numeric_matchers.greaterThan(4));
           src__matcher__expect.expect(list, JSArrayOfString().of(["a"]));
         }, dynamicTodynamic()));
       }, VoidTodynamic()));
       unittest$.group("at index", dart.fn(() => {
         function f() {
           return dart.asyncStar(function*(stream) {
             try {
               if (stream.add(yield async.Future.microtask(dart.fn(() => 1, VoidToint())))) return;
               yield;
             } finally {
               try {
                 if (stream.add(yield async.Future.microtask(dart.fn(() => 2, VoidToint())))) return;
                 yield;
               } finally {
                 if (stream.add(yield async.Future.microtask(dart.fn(() => 3, VoidToint())))) return;
                 yield;
               }
             }
           }, dart.dynamic);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStream());
         unittest$.test("- all, sanity check", dart.fn(() => async_star_test_03_multi.expectList(f(), JSArrayOfint().of([1, 2, 3])), VoidTodynamic()));
-        unittest$.test("after end", dart.fn(() => async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 4), JSArrayOfint().of([1, 2, 3])), VoidTodynamic()));
-        unittest$.test("at end", dart.fn(() => async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 3), JSArrayOfint().of([1, 2, 3])), VoidTodynamic()));
-        unittest$.test("before end", dart.fn(() => async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 2), JSArrayOfint().of([1, 2])), VoidTodynamic()));
-        unittest$.test("early", dart.fn(() => async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 1), JSArrayOfint().of([1])), VoidTodynamic()));
-        unittest$.test("at start", dart.fn(() => async_star_test_03_multi.expectList(dart.dsend(f(), 'take', 0), []), VoidTodynamic()));
+        unittest$.test("after end", dart.fn(() => async_star_test_03_multi.expectList(f().take(4), JSArrayOfint().of([1, 2, 3])), VoidTodynamic()));
+        unittest$.test("at end", dart.fn(() => async_star_test_03_multi.expectList(f().take(3), JSArrayOfint().of([1, 2, 3])), VoidTodynamic()));
+        unittest$.test("before end", dart.fn(() => async_star_test_03_multi.expectList(f().take(2), JSArrayOfint().of([1, 2])), VoidTodynamic()));
+        unittest$.test("early", dart.fn(() => async_star_test_03_multi.expectList(f().take(1), JSArrayOfint().of([1])), VoidTodynamic()));
+        unittest$.test("at start", dart.fn(() => async_star_test_03_multi.expectList(f().take(0), []), VoidTodynamic()));
       }, VoidTovoid()));
     }, VoidTovoid()));
     unittest$.group("pausing", dart.fn(() => {
       unittest$.test("pauses execution at yield for at least a microtask", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             list[dartx.add](1);
             if (stream.add(2)) return;
             yield;
             list[dartx.add](3);
             if (stream.add(4)) return;
             yield;
             list[dartx.add](5);
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         let done = async.Completer.new();
-        let sub = dart.dsend(f(), 'listen', dart.fn(v => {
-          if (dart.equals(v, 2)) {
+        let sub = f().listen(dart.fn(v => {
+          if (v == 2) {
             src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([1])));
-          } else if (dart.equals(v, 4)) {
+          } else if (v == 4) {
             src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([1, 3])));
           } else {
             src__matcher__expect.fail(dart.str`Unexpected value ${v}`);
           }
-        }, dynamicTodynamic()), {onDone: dart.fn(() => {
+        }, intTovoid()), {onDone: dart.fn(() => {
             src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([1, 3, 5])));
             done.complete();
-          }, VoidTodynamic())});
+          }, VoidTovoid())});
         return done.future;
       }, VoidToFuture()));
       unittest$.test("pause stops execution at yield", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             list[dartx.add](1);
             if (stream.add(2)) return;
             yield;
             list[dartx.add](3);
             if (stream.add(4)) return;
             yield;
             list[dartx.add](5);
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         let done = async.Completer.new();
         let sub = null;
-        sub = dart.dsend(f(), 'listen', dart.fn(v => {
-          if (dart.equals(v, 2)) {
+        sub = f().listen(dart.fn(v => {
+          if (v == 2) {
             src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([1])));
             dart.dsend(sub, 'pause');
             async.Timer.new(async_star_test_03_multi.MS['*'](300), dart.fn(() => {
               src__matcher__expect.expect(list[dartx.length], src__matcher__numeric_matchers.lessThan(3));
               dart.dsend(sub, 'resume');
             }, VoidTovoid()));
-          } else if (dart.equals(v, 4)) {
+          } else if (v == 4) {
             src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([1, 3])));
           } else {
             src__matcher__expect.fail(dart.str`Unexpected value ${v}`);
           }
-        }, dynamicTodynamic()), {onDone: dart.fn(() => {
+        }, intTovoid()), {onDone: dart.fn(() => {
             src__matcher__expect.expect(list, src__matcher__core_matchers.equals(JSArrayOfint().of([1, 3, 5])));
             done.complete();
-          }, VoidTodynamic())});
+          }, VoidTovoid())});
         return done.future;
       }, VoidToFuture()));
       unittest$.test("pause stops execution at yield 2", dart.fn(() => {
         let list = [];
         function f() {
           return dart.asyncStar(function*(stream) {
             let i = 0;
             while (true) {
               if (stream.add(i)) return;
               yield;
               list[dartx.add](i);
               i++;
             }
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
+        dart.fn(f, VoidToStreamOfint());
         let expected = 0;
         let done = async.Completer.new();
         let sub = null;
-        sub = dart.dsend(f(), 'listen', dart.fn(v => {
+        sub = f().listen(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals(expected++));
-          if (dart.equals(dart.dsend(v, '%', 5), 0)) {
+          if (v[dartx['%']](5) == 0) {
             dart.dsend(sub, 'pause', async.Future.delayed(async_star_test_03_multi.MS['*'](300)));
-          } else if (dart.equals(v, 17)) {
+          } else if (v == 17) {
             dart.dsend(sub, 'cancel');
             done.complete();
           }
-        }, dynamicTodynamic()), {onDone: dart.fn(() => {
+        }, intTovoid()), {onDone: dart.fn(() => {
             src__matcher__expect.fail("Unexpected done!");
-          }, VoidTodynamic())});
+          }, VoidTovoid())});
         return done.future.whenComplete(dart.fn(() => {
           src__matcher__expect.expect(list[dartx.length] == 18 || list[dartx.length] == 19, src__matcher__core_matchers.isTrue);
         }, VoidTodynamic()));
       }, VoidToFuture()));
     }, VoidTovoid()));
     unittest$.group("await for", dart.fn(() => {
       function mkStream(n) {
         return dart.asyncStar(function*(stream, n) {
           for (let i = 0; i < dart.notNull(n); i++) {
             if (stream.add(i)) return;
             yield;
           }
-        }, dart.dynamic, n);
+        }, core.int, n);
       }
-      dart.fn(mkStream, intTodynamic());
+      dart.fn(mkStream, intToStreamOfint());
       unittest$.test("simple stream", dart.fn(() => {
         function f(s) {
           return dart.async(function*(s) {
             let r = 0;
             let it = async.StreamIterator.new(async.Stream._check(s));
             try {
               while (yield it.moveNext()) {
                 let v = it.current;
                 r = dart.notNull(r) + dart.notNull(core.int._check(v));
               }
             } finally {
               yield it.cancel();
             }
             return r;
-          }, dart.dynamic, s);
+          }, core.int, s);
         }
-        dart.fn(f, dynamicTodynamic());
-        return dart.dsend(f(mkStream(5)), 'then', dart.fn(v => {
+        dart.fn(f, dynamicToFutureOfint());
+        return f(mkStream(5)).then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals(10));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, intTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("simple stream, await", dart.fn(() => {
         function f(s) {
           return dart.async(function*(s) {
             let r = 0;
             let it = async.StreamIterator.new(async.Stream._check(s));
             try {
               while (yield it.moveNext()) {
                 let v = it.current;
                 r = dart.notNull(r) + dart.notNull(core.int._check(yield async.Future.microtask(dart.fn(() => v, VoidTodynamic()))));
               }
             } finally {
               yield it.cancel();
             }
             return r;
-          }, dart.dynamic, s);
+          }, core.int, s);
         }
-        dart.fn(f, dynamicTodynamic());
-        return dart.dsend(f(mkStream(5)), 'then', dart.fn(v => {
+        dart.fn(f, dynamicToFutureOfint());
+        return f(mkStream(5)).then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals(10));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, intTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("simple stream - take", dart.fn(() => {
         function f(s) {
           return dart.async(function*(s) {
             let r = 0;
             let it = async.StreamIterator.new(async.Stream._check(dart.dsend(s, 'take', 5)));
             try {
               while (yield it.moveNext()) {
                 let v = it.current;
                 r = dart.notNull(r) + dart.notNull(core.int._check(v));
               }
             } finally {
               yield it.cancel();
             }
             return r;
-          }, dart.dynamic, s);
+          }, core.int, s);
         }
-        dart.fn(f, dynamicTodynamic());
-        return dart.dsend(f(mkStream(10)), 'then', dart.fn(v => {
+        dart.fn(f, dynamicToFutureOfint());
+        return f(mkStream(10)).then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals(10));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, intTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("simple stream reyield", dart.fn(() => {
         function f(s) {
           return dart.asyncStar(function*(stream, s) {
             let r = 0;
             let it = async.StreamIterator.new(async.Stream._check(s));
             try {
               while (yield it.moveNext()) {
                 let v = it.current;
                 if (stream.add((r = dart.notNull(r) + dart.notNull(core.int._check(v))))) return;
                 yield;
               }
             } finally {
               yield it.cancel();
             }
-          }, dart.dynamic, s);
+          }, core.num, s);
         }
-        dart.fn(f, dynamicTodynamic());
+        dart.fn(f, dynamicToStreamOfnum());
         return async_star_test_03_multi.expectList(f(mkStream(5)), JSArrayOfint().of([0, 1, 3, 6, 10]));
       }, VoidTodynamic()));
       unittest$.test("simple stream, await, reyield", dart.fn(() => {
         function f(s) {
           return dart.asyncStar(function*(stream, s) {
             let r = 0;
             let it = async.StreamIterator.new(async.Stream._check(s));
             try {
               while (yield it.moveNext()) {
                 let v = it.current;
                 if (stream.add((r = dart.notNull(r) + dart.notNull(core.int._check(yield async.Future.microtask(dart.fn(() => v, VoidTodynamic()))))))) return;
                 yield;
               }
             } finally {
               yield it.cancel();
             }
-          }, dart.dynamic, s);
+          }, core.num, s);
         }
-        dart.fn(f, dynamicTodynamic());
+        dart.fn(f, dynamicToStreamOfnum());
         return async_star_test_03_multi.expectList(f(mkStream(5)), JSArrayOfint().of([0, 1, 3, 6, 10]));
       }, VoidTodynamic()));
       unittest$.test("nested", dart.fn(() => {
         function f() {
           return dart.async(function*() {
             let r = 0;
-            let it = async.StreamIterator.new(async.Stream._check(mkStream(5)));
+            let it = async.StreamIterator.new(mkStream(5));
             try {
               while (yield it.moveNext()) {
                 let i = it.current;
-                let it$ = async.StreamIterator.new(async.Stream._check(mkStream(3)));
+                let it$ = async.StreamIterator.new(mkStream(3));
                 try {
                   while (yield it$.moveNext()) {
                     let j = it$.current;
-                    r = dart.notNull(r) + dart.notNull(core.int._check(dart.dsend(i, '*', j)));
+                    r = r + dart.notNull(i) * dart.notNull(j);
                   }
                 } finally {
                   yield it$.cancel();
                 }
               }
             } finally {
               yield it.cancel();
             }
             return r;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(f(), 'then', dart.fn(v => {
+        dart.fn(f, VoidToFutureOfint());
+        return f().then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals((1 + 2 + 3 + 4) * (1 + 2)));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, intTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("nested, await", dart.fn(() => {
         function f() {
           return dart.async(function*() {
             let r = 0;
-            let it = async.StreamIterator.new(async.Stream._check(mkStream(5)));
+            let it = async.StreamIterator.new(mkStream(5));
             try {
               while (yield it.moveNext()) {
                 let i = it.current;
-                let it$ = async.StreamIterator.new(async.Stream._check(mkStream(3)));
+                let it$ = async.StreamIterator.new(mkStream(3));
                 try {
                   while (yield it$.moveNext()) {
                     let j = it$.current;
-                    r = dart.notNull(r) + dart.notNull(core.int._check(yield async.Future.microtask(dart.fn(() => dart.dsend(i, '*', j), VoidTodynamic()))));
+                    r = dart.notNull(r) + dart.notNull(core.int._check(yield async.Future.microtask(dart.fn(() => dart.notNull(i) * dart.notNull(j), VoidToint()))));
                   }
                 } finally {
                   yield it$.cancel();
                 }
               }
             } finally {
               yield it.cancel();
             }
             return r;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(f(), 'then', dart.fn(v => {
+        dart.fn(f, VoidToFutureOfint());
+        return f().then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals((1 + 2 + 3 + 4) * (1 + 2)));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, intTodynamic()));
+      }, VoidToFuture()));
       unittest$.test("nested, await * 2", dart.fn(() => {
         function f() {
           return dart.async(function*() {
             let r = 0;
-            let it = async.StreamIterator.new(async.Stream._check(mkStream(5)));
+            let it = async.StreamIterator.new(mkStream(5));
             try {
               while (yield it.moveNext()) {
                 let i = it.current;
-                let ai = (yield async.Future.microtask(dart.fn(() => i, VoidTodynamic())));
-                let it$ = async.StreamIterator.new(async.Stream._check(mkStream(3)));
+                let ai = (yield async.Future.microtask(dart.fn(() => i, VoidToint())));
+                let it$ = async.StreamIterator.new(mkStream(3));
                 try {
                   while (yield it$.moveNext()) {
                     let j = it$.current;
                     r = dart.notNull(r) + dart.notNull(core.int._check(yield async.Future.microtask(dart.fn(() => dart.dsend(ai, '*', j), VoidTodynamic()))));
                   }
                 } finally {
                   yield it$.cancel();
                 }
               }
             } finally {
               yield it.cancel();
             }
             return r;
-          }, dart.dynamic);
+          }, core.int);
         }
-        dart.fn(f, VoidTodynamic());
-        return dart.dsend(f(), 'then', dart.fn(v => {
+        dart.fn(f, VoidToFutureOfint());
+        return f().then(dart.dynamic)(dart.fn(v => {
           src__matcher__expect.expect(v, src__matcher__core_matchers.equals((1 + 2 + 3 + 4) * (1 + 2)));
-        }, dynamicTodynamic()));
-      }, VoidTodynamic()));
+        }, intTodynamic()));
+      }, VoidToFuture()));
     }, VoidTovoid()));
   };
   dart.fn(async_star_test_03_multi.main, VoidTodynamic());
   async_star_test_03_multi.id = function(x) {
     try {
       if (x != null) dart.throw(x);
     } catch (e) {
       return e;
     }
 
@@ skipping 51 matching lines @@
   };
   dart.setSignature(async_star_test_03_multi.Sync, {
     methods: () => ({
       wait: dart.definiteFunctionType(async.Future, [], [dart.dynamic]),
       release: dart.definiteFunctionType(dart.void, [], [dart.dynamic])
     })
   });
   // Exports:
   exports.async_star_test_03_multi = async_star_test_03_multi;
 });