Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(221)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: test/dart_codegen/expect/async/stream.dart

Issue 967933005: rename ddc -> dev_compiler, fixes #84 (Closed) Base URL: git@github.com:dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « test/dart_codegen/expect/async/schedule_microtask.dart ('k') | test/dart_codegen/expect/async/stream_controller.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: test/dart_codegen/expect/async/stream.dart
diff --git a/test/dart_codegen/expect/async/stream.dart b/test/dart_codegen/expect/async/stream.dart
index 4d7d6b9f4b7824ea600c0ce39fbf6e2c14a68fb7..aa075892b27c4bd04c1d3d274e12d9c65459f8d4 100644
--- a/test/dart_codegen/expect/async/stream.dart
+++ b/test/dart_codegen/expect/async/stream.dart
@@ -1,17 +1,17 @@
part of dart.async;
abstract class Stream<T> {Stream();
factory Stream.fromFuture(Future<T> future) {
- _StreamController<T> controller = ((__x37) => DDC$RT.cast(__x37, DDC$RT.type((StreamController<T> _) {
+ _StreamController<T> controller = ((__x37) => DEVC$RT.cast(__x37, DEVC$RT.type((StreamController<T> _) {
}
- ), DDC$RT.type((_StreamController<T> _) {
+ ), DEVC$RT.type((_StreamController<T> _) {
}
), "CastExact", """line 87, column 39 of dart:async/stream.dart: """, __x37 is _StreamController<T>, false))(new StreamController<T>(sync: true));
future.then((value) {
- controller._add(DDC$RT.cast(value, dynamic, T, "CastGeneral", """line 89, column 25 of dart:async/stream.dart: """, value is T, false));
+ controller._add(DEVC$RT.cast(value, dynamic, T, "CastGeneral", """line 89, column 25 of dart:async/stream.dart: """, value is T, false));
controller._closeUnchecked();
}
, onError: (error, stackTrace) {
- controller._addError(error, DDC$RT.cast(stackTrace, dynamic, StackTrace, "CastGeneral", """line 93, column 37 of dart:async/stream.dart: """, stackTrace is StackTrace, true));
+ controller._addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "CastGeneral", """line 93, column 37 of dart:async/stream.dart: """, stackTrace is StackTrace, true));
controller._closeUnchecked();
}
);
@@ -64,19 +64,19 @@ part of dart.async;
return controller.stream;
}
factory Stream.eventTransformed(Stream source, EventSink mapSink(EventSink<T> sink)) {
- return ((__x38) => DDC$RT.cast(__x38, DDC$RT.type((_BoundSinkStream<dynamic, dynamic> _) {
+ return ((__x38) => DEVC$RT.cast(__x38, DEVC$RT.type((_BoundSinkStream<dynamic, dynamic> _) {
}
- ), DDC$RT.type((Stream<T> _) {
+ ), DEVC$RT.type((Stream<T> _) {
}
- ), "CastExact", """line 216, column 12 of dart:async/stream.dart: """, __x38 is Stream<T>, false))(new _BoundSinkStream(source, DDC$RT.wrap((EventSink<dynamic> f(EventSink<T> __u39)) {
- EventSink<dynamic> c(EventSink<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((EventSink<dynamic> _) {
+ ), "CastExact", """line 216, column 12 of dart:async/stream.dart: """, __x38 is Stream<T>, false))(new _BoundSinkStream(source, DEVC$RT.wrap((EventSink<dynamic> f(EventSink<T> __u39)) {
+ EventSink<dynamic> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dynamic> _) {
}
- ), DDC$RT.type((EventSink<T> _) {
+ ), DEVC$RT.type((EventSink<T> _) {
}
), "CastParam", """line 216, column 41 of dart:async/stream.dart: """, x0 is EventSink<T>, false));
return f == null ? null : c;
}
- , mapSink, DDC$RT.type((__t42<T> _) {
+ , mapSink, DEVC$RT.type((__t42<T> _) {
}
), __t40, "Wrap", """line 216, column 41 of dart:async/stream.dart: """, mapSink is __t40)));
}
@@ -84,25 +84,25 @@ part of dart.async;
Stream<T> asBroadcastStream({
void onListen(StreamSubscription<T> subscription), void onCancel(StreamSubscription<T> subscription)}
) {
- return new _AsBroadcastStream<T>(this, DDC$RT.wrap((void f(StreamSubscription<T> __u44)) {
- void c(StreamSubscription<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((StreamSubscription<dynamic> _) {
+ return new _AsBroadcastStream<T>(this, DEVC$RT.wrap((void f(StreamSubscription<T> __u44)) {
+ void c(StreamSubscription<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((StreamSubscription<dynamic> _) {
}
- ), DDC$RT.type((StreamSubscription<T> _) {
+ ), DEVC$RT.type((StreamSubscription<T> _) {
}
), "CastParam", """line 248, column 44 of dart:async/stream.dart: """, x0 is StreamSubscription<T>, false));
return f == null ? null : c;
}
- , onListen, DDC$RT.type((__t47<T> _) {
+ , onListen, DEVC$RT.type((__t47<T> _) {
}
- ), __t45, "Wrap", """line 248, column 44 of dart:async/stream.dart: """, onListen is __t45), DDC$RT.wrap((void f(StreamSubscription<T> __u49)) {
- void c(StreamSubscription<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((StreamSubscription<dynamic> _) {
+ ), __t45, "Wrap", """line 248, column 44 of dart:async/stream.dart: """, onListen is __t45), DEVC$RT.wrap((void f(StreamSubscription<T> __u49)) {
+ void c(StreamSubscription<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((StreamSubscription<dynamic> _) {
}
- ), DDC$RT.type((StreamSubscription<T> _) {
+ ), DEVC$RT.type((StreamSubscription<T> _) {
}
), "CastParam", """line 248, column 54 of dart:async/stream.dart: """, x0 is StreamSubscription<T>, false));
return f == null ? null : c;
}
- , onCancel, DDC$RT.type((__t47<T> _) {
+ , onCancel, DEVC$RT.type((__t47<T> _) {
}
), __t45, "Wrap", """line 248, column 54 of dart:async/stream.dart: """, onCancel is __t45));
}
@@ -138,7 +138,7 @@ part of dart.async;
controller.add(newValue);
}
}
- , onError: DDC$RT.cast(addError, dynamic, Function, "CastGeneral", """line 338, column 20 of dart:async/stream.dart: """, addError is Function, true), onDone: controller.close);
+ , onError: DEVC$RT.cast(addError, dynamic, Function, "CastGeneral", """line 338, column 20 of dart:async/stream.dart: """, addError is Function, true), onDone: controller.close);
}
if (this.isBroadcast) {
controller = new StreamController.broadcast(onListen: onListen, onCancel: () {
@@ -178,7 +178,7 @@ part of dart.async;
controller.addStream(newStream).whenComplete(subscription.resume);
}
}
- , onError: DDC$RT.cast(eventSink._addError, dynamic, Function, "CastGeneral", """line 395, column 20 of dart:async/stream.dart: """, eventSink._addError is Function, true), onDone: controller.close);
+ , onError: DEVC$RT.cast(eventSink._addError, dynamic, Function, "CastGeneral", """line 395, column 20 of dart:async/stream.dart: """, eventSink._addError is Function, true), onDone: controller.close);
}
if (this.isBroadcast) {
controller = new StreamController.broadcast(onListen: onListen, onCancel: () {
@@ -221,16 +221,16 @@ part of dart.async;
StreamSubscription subscription;
subscription = this.listen((T element) {
if (seenFirst) {
- _runUserCode(() => combine(value, element), ((__x55) => DDC$RT.wrap((dynamic f(T __u50)) {
- dynamic c(T x0) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 500, column 24 of dart:async/stream.dart: """, x0 is T, false));
+ _runUserCode(() => combine(value, element), ((__x55) => DEVC$RT.wrap((dynamic f(T __u50)) {
+ dynamic c(T x0) => f(DEVC$RT.cast(x0, dynamic, T, "CastParam", """line 500, column 24 of dart:async/stream.dart: """, x0 is T, false));
return f == null ? null : c;
}
- , __x55, DDC$RT.type((__t53<T> _) {
+ , __x55, DEVC$RT.type((__t53<T> _) {
}
), __t51, "WrapLiteral", """line 500, column 24 of dart:async/stream.dart: """, __x55 is __t51))((T newValue) {
value = newValue;
}
- ), ((__x59) => DDC$RT.cast(__x59, dynamic, __t56, "CastGeneral", """line 501, column 24 of dart:async/stream.dart: """, __x59 is __t56, false))(_cancelAndErrorClosure(subscription, result)));
+ ), ((__x59) => DEVC$RT.cast(__x59, dynamic, __t56, "CastGeneral", """line 501, column 24 of dart:async/stream.dart: """, __x59 is __t56, false))(_cancelAndErrorClosure(subscription, result)));
}
else {
value = element;
@@ -261,10 +261,10 @@ part of dart.async;
_runUserCode(() => combine(value, element), (newValue) {
value = newValue;
}
- , ((__x60) => DDC$RT.cast(__x60, dynamic, __t56, "CastGeneral", """line 534, column 11 of dart:async/stream.dart: """, __x60 is __t56, false))(_cancelAndErrorClosure(subscription, result)));
+ , ((__x60) => DEVC$RT.cast(__x60, dynamic, __t56, "CastGeneral", """line 534, column 11 of dart:async/stream.dart: """, __x60 is __t56, false))(_cancelAndErrorClosure(subscription, result)));
}
, onError: (e, st) {
- result._completeError(e, DDC$RT.cast(st, dynamic, StackTrace, "CastGeneral", """line 538, column 34 of dart:async/stream.dart: """, st is StackTrace, true));
+ result._completeError(e, DEVC$RT.cast(st, dynamic, StackTrace, "CastGeneral", """line 538, column 34 of dart:async/stream.dart: """, st is StackTrace, true));
}
, onDone: () {
result._complete(value);
@@ -302,8 +302,8 @@ part of dart.async;
_Future<bool> future = new _Future<bool>();
StreamSubscription subscription;
subscription = this.listen((T element) {
- _runUserCode(() => (element == needle), ((__x64) => DDC$RT.wrap((dynamic f(bool __u61)) {
- dynamic c(bool x0) => f(DDC$RT.cast(x0, dynamic, bool, "CastParam", """line 597, column 13 of dart:async/stream.dart: """, x0 is bool, true));
+ _runUserCode(() => (element == needle), ((__x64) => DEVC$RT.wrap((dynamic f(bool __u61)) {
+ dynamic c(bool x0) => f(DEVC$RT.cast(x0, dynamic, bool, "CastParam", """line 597, column 13 of dart:async/stream.dart: """, x0 is bool, true));
return f == null ? null : c;
}
, __x64, __t62, __t51, "WrapLiteral", """line 597, column 13 of dart:async/stream.dart: """, __x64 is __t51))((bool isMatch) {
@@ -311,7 +311,7 @@ part of dart.async;
_cancelAndValue(subscription, future, true);
}
}
- ), ((__x65) => DDC$RT.cast(__x65, dynamic, __t56, "CastGeneral", """line 602, column 13 of dart:async/stream.dart: """, __x65 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ ), ((__x65) => DEVC$RT.cast(__x65, dynamic, __t56, "CastGeneral", """line 602, column 13 of dart:async/stream.dart: """, __x65 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
future._complete(false);
@@ -325,7 +325,7 @@ part of dart.async;
subscription = this.listen((T element) {
_runUserCode(() => action(element), (_) {
}
- , ((__x66) => DDC$RT.cast(__x66, dynamic, __t56, "CastGeneral", """line 628, column 13 of dart:async/stream.dart: """, __x66 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ , ((__x66) => DEVC$RT.cast(__x66, dynamic, __t56, "CastGeneral", """line 628, column 13 of dart:async/stream.dart: """, __x66 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
future._complete(null);
@@ -337,8 +337,8 @@ part of dart.async;
_Future<bool> future = new _Future<bool>();
StreamSubscription subscription;
subscription = this.listen((T element) {
- _runUserCode(() => test(element), ((__x68) => DDC$RT.wrap((dynamic f(bool __u67)) {
- dynamic c(bool x0) => f(DDC$RT.cast(x0, dynamic, bool, "CastParam", """line 652, column 13 of dart:async/stream.dart: """, x0 is bool, true));
+ _runUserCode(() => test(element), ((__x68) => DEVC$RT.wrap((dynamic f(bool __u67)) {
+ dynamic c(bool x0) => f(DEVC$RT.cast(x0, dynamic, bool, "CastParam", """line 652, column 13 of dart:async/stream.dart: """, x0 is bool, true));
return f == null ? null : c;
}
, __x68, __t62, __t51, "WrapLiteral", """line 652, column 13 of dart:async/stream.dart: """, __x68 is __t51))((bool isMatch) {
@@ -346,7 +346,7 @@ part of dart.async;
_cancelAndValue(subscription, future, false);
}
}
- ), ((__x69) => DDC$RT.cast(__x69, dynamic, __t56, "CastGeneral", """line 657, column 13 of dart:async/stream.dart: """, __x69 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ ), ((__x69) => DEVC$RT.cast(__x69, dynamic, __t56, "CastGeneral", """line 657, column 13 of dart:async/stream.dart: """, __x69 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
future._complete(true);
@@ -358,8 +358,8 @@ part of dart.async;
_Future<bool> future = new _Future<bool>();
StreamSubscription subscription;
subscription = this.listen((T element) {
- _runUserCode(() => test(element), ((__x71) => DDC$RT.wrap((dynamic f(bool __u70)) {
- dynamic c(bool x0) => f(DDC$RT.cast(x0, dynamic, bool, "CastParam", """line 689, column 13 of dart:async/stream.dart: """, x0 is bool, true));
+ _runUserCode(() => test(element), ((__x71) => DEVC$RT.wrap((dynamic f(bool __u70)) {
+ dynamic c(bool x0) => f(DEVC$RT.cast(x0, dynamic, bool, "CastParam", """line 689, column 13 of dart:async/stream.dart: """, x0 is bool, true));
return f == null ? null : c;
}
, __x71, __t62, __t51, "WrapLiteral", """line 689, column 13 of dart:async/stream.dart: """, __x71 is __t51))((bool isMatch) {
@@ -367,7 +367,7 @@ part of dart.async;
_cancelAndValue(subscription, future, true);
}
}
- ), ((__x72) => DDC$RT.cast(__x72, dynamic, __t56, "CastGeneral", """line 694, column 13 of dart:async/stream.dart: """, __x72 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ ), ((__x72) => DEVC$RT.cast(__x72, dynamic, __t56, "CastGeneral", """line 694, column 13 of dart:async/stream.dart: """, __x72 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
future._complete(false);
@@ -425,55 +425,55 @@ part of dart.async;
}
Future drain([var futureValue]) => listen(null, cancelOnError: true).asFuture(futureValue);
Stream<T> take(int count) {
- return ((__x73) => DDC$RT.cast(__x73, DDC$RT.type((_TakeStream<dynamic> _) {
+ return ((__x73) => DEVC$RT.cast(__x73, DEVC$RT.type((_TakeStream<dynamic> _) {
}
- ), DDC$RT.type((Stream<T> _) {
+ ), DEVC$RT.type((Stream<T> _) {
}
), "CastExact", """line 819, column 12 of dart:async/stream.dart: """, __x73 is Stream<T>, false))(new _TakeStream(this, count));
}
Stream<T> takeWhile(bool test(T element)) {
- return ((__x74) => DDC$RT.cast(__x74, DDC$RT.type((_TakeWhileStream<dynamic> _) {
+ return ((__x74) => DEVC$RT.cast(__x74, DEVC$RT.type((_TakeWhileStream<dynamic> _) {
}
- ), DDC$RT.type((Stream<T> _) {
+ ), DEVC$RT.type((Stream<T> _) {
}
- ), "CastExact", """line 841, column 12 of dart:async/stream.dart: """, __x74 is Stream<T>, false))(new _TakeWhileStream(this, DDC$RT.wrap((bool f(T __u75)) {
- bool c(T x0) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 841, column 39 of dart:async/stream.dart: """, x0 is T, false));
+ ), "CastExact", """line 841, column 12 of dart:async/stream.dart: """, __x74 is Stream<T>, false))(new _TakeWhileStream(this, DEVC$RT.wrap((bool f(T __u75)) {
+ bool c(T x0) => f(DEVC$RT.cast(x0, dynamic, T, "CastParam", """line 841, column 39 of dart:async/stream.dart: """, x0 is T, false));
return f == null ? null : c;
}
- , test, DDC$RT.type((__t78<T> _) {
+ , test, DEVC$RT.type((__t78<T> _) {
}
), __t76, "Wrap", """line 841, column 39 of dart:async/stream.dart: """, test is __t76)));
}
Stream<T> skip(int count) {
- return ((__x80) => DDC$RT.cast(__x80, DDC$RT.type((_SkipStream<dynamic> _) {
+ return ((__x80) => DEVC$RT.cast(__x80, DEVC$RT.type((_SkipStream<dynamic> _) {
}
- ), DDC$RT.type((Stream<T> _) {
+ ), DEVC$RT.type((Stream<T> _) {
}
), "CastExact", """line 852, column 12 of dart:async/stream.dart: """, __x80 is Stream<T>, false))(new _SkipStream(this, count));
}
Stream<T> skipWhile(bool test(T element)) {
- return ((__x81) => DDC$RT.cast(__x81, DDC$RT.type((_SkipWhileStream<dynamic> _) {
+ return ((__x81) => DEVC$RT.cast(__x81, DEVC$RT.type((_SkipWhileStream<dynamic> _) {
}
- ), DDC$RT.type((Stream<T> _) {
+ ), DEVC$RT.type((Stream<T> _) {
}
- ), "CastExact", """line 868, column 12 of dart:async/stream.dart: """, __x81 is Stream<T>, false))(new _SkipWhileStream(this, DDC$RT.wrap((bool f(T __u82)) {
- bool c(T x0) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 868, column 39 of dart:async/stream.dart: """, x0 is T, false));
+ ), "CastExact", """line 868, column 12 of dart:async/stream.dart: """, __x81 is Stream<T>, false))(new _SkipWhileStream(this, DEVC$RT.wrap((bool f(T __u82)) {
+ bool c(T x0) => f(DEVC$RT.cast(x0, dynamic, T, "CastParam", """line 868, column 39 of dart:async/stream.dart: """, x0 is T, false));
return f == null ? null : c;
}
- , test, DDC$RT.type((__t78<T> _) {
+ , test, DEVC$RT.type((__t78<T> _) {
}
), __t76, "Wrap", """line 868, column 39 of dart:async/stream.dart: """, test is __t76)));
}
Stream<T> distinct([bool equals(T previous, T next)]) {
- return ((__x83) => DDC$RT.cast(__x83, DDC$RT.type((_DistinctStream<dynamic> _) {
+ return ((__x83) => DEVC$RT.cast(__x83, DEVC$RT.type((_DistinctStream<dynamic> _) {
}
- ), DDC$RT.type((Stream<T> _) {
+ ), DEVC$RT.type((Stream<T> _) {
}
- ), "CastExact", """line 885, column 12 of dart:async/stream.dart: """, __x83 is Stream<T>, false))(new _DistinctStream(this, DDC$RT.wrap((bool f(T __u84, T __u85)) {
- bool c(T x0, T x1) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 885, column 38 of dart:async/stream.dart: """, x0 is T, false), DDC$RT.cast(x1, dynamic, T, "CastParam", """line 885, column 38 of dart:async/stream.dart: """, x1 is T, false));
+ ), "CastExact", """line 885, column 12 of dart:async/stream.dart: """, __x83 is Stream<T>, false))(new _DistinctStream(this, DEVC$RT.wrap((bool f(T __u84, T __u85)) {
+ bool c(T x0, T x1) => f(DEVC$RT.cast(x0, dynamic, T, "CastParam", """line 885, column 38 of dart:async/stream.dart: """, x0 is T, false), DEVC$RT.cast(x1, dynamic, T, "CastParam", """line 885, column 38 of dart:async/stream.dart: """, x1 is T, false));
return f == null ? null : c;
}
- , equals, DDC$RT.type((__t89<T> _) {
+ , equals, DEVC$RT.type((__t89<T> _) {
}
), __t86, "Wrap", """line 885, column 38 of dart:async/stream.dart: """, equals is __t86)));
}
@@ -554,8 +554,8 @@ part of dart.async;
_Future<dynamic> future = new _Future();
StreamSubscription subscription;
subscription = this.listen((T value) {
- _runUserCode(() => test(value), ((__x93) => DDC$RT.wrap((dynamic f(bool __u92)) {
- dynamic c(bool x0) => f(DDC$RT.cast(x0, dynamic, bool, "CastParam", """line 1031, column 11 of dart:async/stream.dart: """, x0 is bool, true));
+ _runUserCode(() => test(value), ((__x93) => DEVC$RT.wrap((dynamic f(bool __u92)) {
+ dynamic c(bool x0) => f(DEVC$RT.cast(x0, dynamic, bool, "CastParam", """line 1031, column 11 of dart:async/stream.dart: """, x0 is bool, true));
return f == null ? null : c;
}
, __x93, __t62, __t51, "WrapLiteral", """line 1031, column 11 of dart:async/stream.dart: """, __x93 is __t51))((bool isMatch) {
@@ -563,7 +563,7 @@ part of dart.async;
_cancelAndValue(subscription, future, value);
}
}
- ), ((__x94) => DDC$RT.cast(__x94, dynamic, __t56, "CastGeneral", """line 1036, column 11 of dart:async/stream.dart: """, __x94 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ ), ((__x94) => DEVC$RT.cast(__x94, dynamic, __t56, "CastGeneral", """line 1036, column 11 of dart:async/stream.dart: """, __x94 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
if (defaultValue != null) {
@@ -587,8 +587,8 @@ part of dart.async;
bool foundResult = false;
StreamSubscription subscription;
subscription = this.listen((T value) {
- _runUserCode(() => true == test(value), ((__x96) => DDC$RT.wrap((dynamic f(bool __u95)) {
- dynamic c(bool x0) => f(DDC$RT.cast(x0, dynamic, bool, "CastParam", """line 1071, column 11 of dart:async/stream.dart: """, x0 is bool, true));
+ _runUserCode(() => true == test(value), ((__x96) => DEVC$RT.wrap((dynamic f(bool __u95)) {
+ dynamic c(bool x0) => f(DEVC$RT.cast(x0, dynamic, bool, "CastParam", """line 1071, column 11 of dart:async/stream.dart: """, x0 is bool, true));
return f == null ? null : c;
}
, __x96, __t62, __t51, "WrapLiteral", """line 1071, column 11 of dart:async/stream.dart: """, __x96 is __t51))((bool isMatch) {
@@ -597,7 +597,7 @@ part of dart.async;
result = value;
}
}
- ), ((__x97) => DDC$RT.cast(__x97, dynamic, __t56, "CastGeneral", """line 1077, column 11 of dart:async/stream.dart: """, __x97 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ ), ((__x97) => DEVC$RT.cast(__x97, dynamic, __t56, "CastGeneral", """line 1077, column 11 of dart:async/stream.dart: """, __x97 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
if (foundResult) {
@@ -622,8 +622,8 @@ part of dart.async;
bool foundResult = false;
StreamSubscription subscription;
subscription = this.listen((T value) {
- _runUserCode(() => true == test(value), ((__x99) => DDC$RT.wrap((dynamic f(bool __u98)) {
- dynamic c(bool x0) => f(DDC$RT.cast(x0, dynamic, bool, "CastParam", """line 1115, column 11 of dart:async/stream.dart: """, x0 is bool, true));
+ _runUserCode(() => true == test(value), ((__x99) => DEVC$RT.wrap((dynamic f(bool __u98)) {
+ dynamic c(bool x0) => f(DEVC$RT.cast(x0, dynamic, bool, "CastParam", """line 1115, column 11 of dart:async/stream.dart: """, x0 is bool, true));
return f == null ? null : c;
}
, __x99, __t62, __t51, "WrapLiteral", """line 1115, column 11 of dart:async/stream.dart: """, __x99 is __t51))((bool isMatch) {
@@ -640,7 +640,7 @@ part of dart.async;
result = value;
}
}
- ), ((__x100) => DDC$RT.cast(__x100, dynamic, __t56, "CastGeneral", """line 1129, column 11 of dart:async/stream.dart: """, __x100 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
+ ), ((__x100) => DEVC$RT.cast(__x100, dynamic, __t56, "CastGeneral", """line 1129, column 11 of dart:async/stream.dart: """, __x100 is __t56, false))(_cancelAndErrorClosure(subscription, future)));
}
, onError: future._completeError, onDone: () {
if (foundResult) {
@@ -684,13 +684,13 @@ part of dart.async;
void onData(T event) {
timer.cancel();
controller.add(event);
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1219, column 43 of dart:async/stream.dart: """, timeout is __t101, false));
+ timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1219, column 43 of dart:async/stream.dart: """, timeout is __t101, false));
}
void onError(error, StackTrace stackTrace) {
timer.cancel();
assert (controller is _StreamController || controller is _BroadcastStreamController); var eventSink = controller;
eventSink._addError(error, stackTrace);
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1227, column 43 of dart:async/stream.dart: """, timeout is __t101, false));
+ timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1227, column 43 of dart:async/stream.dart: """, timeout is __t101, false));
}
void onDone() {
timer.cancel();
@@ -705,8 +705,8 @@ part of dart.async;
;
}
else {
- onTimeout = zone.registerUnaryCallback(DDC$RT.wrap((void f(EventSink<dynamic> __u102)) {
- void c(EventSink<dynamic> x0) => f(DDC$RT.cast(x0, dynamic, DDC$RT.type((EventSink<dynamic> _) {
+ onTimeout = zone.registerUnaryCallback(DEVC$RT.wrap((void f(EventSink<dynamic> __u102)) {
+ void c(EventSink<dynamic> x0) => f(DEVC$RT.cast(x0, dynamic, DEVC$RT.type((EventSink<dynamic> _) {
}
), "CastParam", """line 1245, column 48 of dart:async/stream.dart: """, x0 is EventSink<dynamic>, true));
return f == null ? null : c;
@@ -715,8 +715,8 @@ part of dart.async;
_ControllerEventSinkWrapper wrapper = new _ControllerEventSinkWrapper(null);
timeout = () {
wrapper._sink = controller;
- zone.runUnaryGuarded(DDC$RT.wrap((void f(EventSink<dynamic> __u105)) {
- void c(EventSink<dynamic> x0) => f(DDC$RT.cast(x0, dynamic, DDC$RT.type((EventSink<dynamic> _) {
+ zone.runUnaryGuarded(DEVC$RT.wrap((void f(EventSink<dynamic> __u105)) {
+ void c(EventSink<dynamic> x0) => f(DEVC$RT.cast(x0, dynamic, DEVC$RT.type((EventSink<dynamic> _) {
}
), "CastParam", """line 1250, column 32 of dart:async/stream.dart: """, x0 is EventSink<dynamic>, true));
return f == null ? null : c;
@@ -727,7 +727,7 @@ part of dart.async;
;
}
subscription = this.listen(onData, onError: onError, onDone: onDone);
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1256, column 43 of dart:async/stream.dart: """, timeout is __t101, false));
+ timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1256, column 43 of dart:async/stream.dart: """, timeout is __t101, false));
}
Future onCancel() {
timer.cancel();
@@ -741,7 +741,7 @@ part of dart.async;
}
, () {
subscription.resume();
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1275, column 53 of dart:async/stream.dart: """, timeout is __t101, false));
+ timer = zone.createTimer(timeLimit, DEVC$RT.cast(timeout, Function, __t101, "CastGeneral", """line 1275, column 53 of dart:async/stream.dart: """, timeout is __t101, false));
}
, onCancel);
return controller.stream;
« no previous file with comments | « test/dart_codegen/expect/async/schedule_microtask.dart ('k') | test/dart_codegen/expect/async/stream_controller.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698