Index: lib/runtime/dart/async.js |
diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js |
index 7199d8541a783e8ff3e44bf23ce1f902566a444f..b576608cd74e93c251f50d353dca793b80e039a6 100644 |
--- a/lib/runtime/dart/async.js |
+++ b/lib/runtime/dart/async.js |
@@ -371,7 +371,7 @@ var async; |
return future; |
} |
toList() { |
- let result = new List.from([]); |
+ let result = new core.List$(T).from([]); |
let future = new _Future(); |
this.listen(((data) => { |
result.add(data); |
@@ -583,7 +583,7 @@ var async; |
return future; |
} |
elementAt(index) { |
- if (dart.notNull(!(typeof index == number)) || dart.notNull(index) < 0) |
+ if (dart.notNull(!(typeof index == 'number')) || dart.notNull(index) < 0) |
throw new core.ArgumentError(index); |
let future = new _Future(); |
let subscription = null; |
@@ -1675,7 +1675,7 @@ var async; |
}).bind(this), {onError: handleError}); |
} |
if (remaining === 0) { |
- return dart.as(new Future.value(/* Unimplemented const */new List.from([])), Future$(core.List)); |
+ return dart.as(new Future.value(/* Unimplemented const */new core.List.from([])), Future$(core.List)); |
} |
values = new core.List(remaining); |
return result; |
@@ -3434,18 +3434,24 @@ var async; |
dart.assert(dart.notNull(this[_state]) >= dart.notNull(_StreamIteratorImpl._STATE_EXTRA_DATA)); |
switch (this[_state]) { |
case _StreamIteratorImpl._STATE_EXTRA_DATA: |
+ { |
this[_state] = _StreamIteratorImpl._STATE_FOUND; |
this[_current$] = dart.as(this[_futureOrPrefetch], T); |
this[_futureOrPrefetch] = null; |
this[_subscription].resume(); |
return new _Future.immediate(true); |
+ } |
case _StreamIteratorImpl._STATE_EXTRA_ERROR: |
+ { |
let prefetch = dart.as(this[_futureOrPrefetch], AsyncError); |
this[_clear](); |
return new _Future.immediateError(prefetch.error, prefetch.stackTrace); |
+ } |
case _StreamIteratorImpl._STATE_EXTRA_DONE: |
+ { |
this[_clear](); |
return new _Future.immediate(false); |
+ } |
} |
} |
} |
@@ -3773,7 +3779,7 @@ var async; |
_TakeStream(source, count) { |
this[_remaining] = count; |
super._ForwardingStream(source); |
- if (!(typeof count == number)) |
+ if (!(typeof count == 'number')) |
throw new core.ArgumentError(count); |
} |
[_handleData](inputEvent, sink) { |
@@ -3821,7 +3827,7 @@ var async; |
_SkipStream(source, count) { |
this[_remaining] = count; |
super._ForwardingStream(source); |
- if (dart.notNull(!(typeof count == number)) || dart.notNull(count) < 0) |
+ if (dart.notNull(!(typeof count == 'number')) || dart.notNull(count) < 0) |
throw new core.ArgumentError(count); |
} |
[_handleData](inputEvent, sink) { |