blob: 4e31263e40837a10a3221984d6335530af0b7c1d [file] [log] [blame]
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>};
}
}