OLD | NEW |
1 library test; | 1 library test; |
2 import self as self; | 2 import self as self; |
3 import "dart:async" as asy; | 3 import "dart:async" as asy; |
4 import "dart:core" as core; | 4 import "dart:core" as core; |
5 | 5 |
6 static method main() → dynamic { | 6 static method main() → dynamic { |
7 () → asy::Stream<core::num> f = () → asy::Stream<core::num> /* originally asyn
c* */ { | 7 () → asy::Stream<core::num> f = () → asy::Stream<core::num> async* { |
8 dynamic :controller; | 8 yield 1; |
9 dynamic :async_op_then; | 9 asy::Stream<core::double> s; |
10 dynamic :async_op_error; | 10 yield* s; |
11 dynamic :await_jump_var = 0; | |
12 dynamic :await_ctx_var; | |
13 dynamic :saved_try_context_var0; | |
14 dynamic :saved_try_context_var1; | |
15 function :async_op([dynamic :result, dynamic :exception, dynamic :stack_trac
e]) → dynamic yielding | |
16 try | |
17 try { | |
18 #L1: | |
19 { | |
20 if(:controller.add(1)) | |
21 return null; | |
22 else | |
23 [yield] null; | |
24 asy::Stream<core::double> s; | |
25 if(:controller.addStream(s)) | |
26 return null; | |
27 else | |
28 [yield] null; | |
29 } | |
30 return; | |
31 } | |
32 on dynamic catch(dynamic :exception, dynamic :stack_trace) { | |
33 :controller.addError(:exception, :stack_trace); | |
34 } | |
35 finally { | |
36 :controller.close(); | |
37 } | |
38 :async_op_then = asy::_asyncThenWrapperHelper(:async_op); | |
39 :async_op_error = asy::_asyncErrorWrapperHelper(:async_op); | |
40 :controller = new asy::_AsyncStarStreamController::•(:async_op); | |
41 return :controller.stream; | |
42 }; | 11 }; |
43 asy::Stream<core::num> g = f.call(); | 12 asy::Stream<core::num> g = f.call(); |
44 asy::Stream<core::int> h = f.call(); | 13 asy::Stream<core::int> h = f.call(); |
45 } | 14 } |
OLD | NEW |