| library #lib; |
| import self as self; |
| import "dart:core" as core; |
| import "dart:ffi" as ffi; |
| import "dart:async" as asy; |
| import "dart:_internal" as _in; |
| |
| import "dart:ffi"; |
| |
| class Foo extends core::Object implements ffi::Finalizable { |
| synthetic constructor •() → self::Foo |
| : super core::Object::•() |
| ; |
| } |
| static method bar() → asy::Future<self::Foo> |
| return asy::Future::value<self::Foo>(new self::Foo::•()); |
| static method main() → void async /* emittedValueType= void */ { |
| { |
| synthesized asy::Stream<self::Foo> :stream = asy::Stream::fromIterable<self::Foo>(core::_GrowableList::_literal1<self::Foo>(await self::bar())); |
| synthesized asy::_StreamIterator<self::Foo>? :for-iterator = new asy::_StreamIterator::•<self::Foo>(:stream); |
| try |
| while (let dynamic #t1 = asy::_asyncStarMoveNextHelper(:stream) in await :for-iterator.{asy::_StreamIterator::moveNext}(){() → asy::Future<core::bool>}) { |
| final self::Foo element = :for-iterator.{asy::_StreamIterator::current}{self::Foo}; |
| { |
| core::print(element); |
| _in::reachabilityFence(element); |
| } |
| } |
| finally |
| if(!(:for-iterator.{asy::_StreamIterator::_subscription}{asy::StreamSubscription<self::Foo>?} == null)) |
| await :for-iterator.{asy::_StreamIterator::cancel}(){() → asy::Future<dynamic>}; |
| } |
| } |