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

Issues Search
    My Issues | Starred     Open | Closed | All

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

Issue 963593002: Disable formatting and add new-lines to make tests faster. (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
« test/dart_codegen/expect/_internal/iterable.dart ('K') | « 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 51aa336ee1838529b720f26f66b080ef144517ce..a8950ed5e1259d6c56fc5e2b230b5c8dc7ce28f0 100644
--- a/test/dart_codegen/expect/async/stream.dart
+++ b/test/dart_codegen/expect/async/stream.dart
@@ -1,803 +1,769 @@
part of dart.async;
-
-abstract class Stream<T> {
- Stream();
- factory Stream.fromFuture(Future<T> future) {
- _StreamController<T> controller = ((__x35) => DDC$RT.cast(__x35,
- DDC$RT.type((StreamController<T> _) {}),
- DDC$RT.type((_StreamController<T> _) {}), "CastExact",
- """line 87, column 39 of dart:async/stream.dart: """,
- __x35 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._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._closeUnchecked();
- });
- return controller.stream;
- }
- factory Stream.fromIterable(Iterable<T> data) {
- return new _GeneratedStreamImpl<T>(
- () => new _IterablePendingEvents<T>(data));
- }
- factory Stream.periodic(Duration period,
- [T computation(int computationCount)]) {
- if (computation == null) computation = ((__x42) => DDC$RT.wrap(
- (dynamic f(dynamic __u37)) {
- dynamic c(dynamic x0) => ((__x36) => DDC$RT.cast(__x36, Null, T,
- "CastResult", """line 126, column 44 of dart:async/stream.dart: """,
- __x36 is T, false))(f(x0));
- return f == null ? null : c;
- }, __x42, __t40, DDC$RT.type((__t38<T> _) {}), "Wrap",
- """line 126, column 44 of dart:async/stream.dart: """,
- __x42 is __t38<T>))(((i) => null));
- Timer timer;
- int computationCount = 0;
- StreamController<T> controller;
- Stopwatch watch = new Stopwatch();
- void sendEvent() {
- watch.reset();
- T data = computation(computationCount++);
- controller.add(data);
- }
- void startPeriodicTimer() {
- assert(timer == null);
- timer = new Timer.periodic(period, (Timer timer) {
- sendEvent();
- });
- }
- controller = new StreamController<T>(sync: true, onListen: () {
- watch.start();
- startPeriodicTimer();
- }, onPause: () {
- timer.cancel();
- timer = null;
- watch.stop();
- }, onResume: () {
- assert(timer == null);
- Duration elapsed = watch.elapsed;
- watch.start();
- timer = new Timer(period - elapsed, () {
- timer = null;
- startPeriodicTimer();
- sendEvent();
- });
- }, onCancel: () {
- if (timer != null) timer.cancel();
+ abstract class Stream<T> {Stream();
+ factory Stream.fromFuture(Future<T> future) {
+ _StreamController<T> controller = ((__x35) => DDC$RT.cast(__x35, DDC$RT.type((StreamController<T> _) {
+ }
+ ), DDC$RT.type((_StreamController<T> _) {
+ }
+ ), "CastExact", """line 87, column 39 of dart:async/stream.dart: """, __x35 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._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._closeUnchecked();
+ }
+ );
+ return controller.stream;
+ }
+ factory Stream.fromIterable(Iterable<T> data) {
+ return new _GeneratedStreamImpl<T>(() => new _IterablePendingEvents<T>(data));
+ }
+ factory Stream.periodic(Duration period, [T computation(int computationCount)]) {
+ if (computation == null) computation = ((__x42) => DDC$RT.wrap((dynamic f(dynamic __u37)) {
+ dynamic c(dynamic x0) => ((__x36) => DDC$RT.cast(__x36, Null, T, "CastResult", """line 126, column 44 of dart:async/stream.dart: """, __x36 is T, false))(f(x0));
+ return f == null ? null : c;
+ }
+ , __x42, __t40, DDC$RT.type((__t38<T> _) {
+ }
+ ), "Wrap", """line 126, column 44 of dart:async/stream.dart: """, __x42 is __t38<T>))(((i) => null));
+ Timer timer;
+ int computationCount = 0;
+ StreamController<T> controller;
+ Stopwatch watch = new Stopwatch();
+ void sendEvent() {
+ watch.reset();
+ T data = computation(computationCount++);
+ controller.add(data);
+ }
+ void startPeriodicTimer() {
+ assert (timer == null); timer = new Timer.periodic(period, (Timer timer) {
+ sendEvent();
+ }
+ );
+ }
+ controller = new StreamController<T>(sync: true, onListen: () {
+ watch.start();
+ startPeriodicTimer();
+ }
+ , onPause: () {
+ timer.cancel();
+ timer = null;
+ watch.stop();
+ }
+ , onResume: () {
+ assert (timer == null); Duration elapsed = watch.elapsed;
+ watch.start();
+ timer = new Timer(period - elapsed, () {
timer = null;
- });
- return controller.stream;
- }
- factory Stream.eventTransformed(
- Stream source, EventSink mapSink(EventSink<T> sink)) {
- return ((__x43) => DDC$RT.cast(__x43,
- DDC$RT.type((_BoundSinkStream<dynamic, dynamic> _) {}),
- DDC$RT.type((Stream<T> _) {}), "CastExact",
- """line 216, column 12 of dart:async/stream.dart: """,
- __x43 is Stream<T>, false))(new _BoundSinkStream(source, mapSink));
- }
- bool get isBroadcast => false;
- Stream<T> asBroadcastStream(
- {void onListen(StreamSubscription<T> subscription),
- void onCancel(StreamSubscription<T> subscription)}) {
- return new _AsBroadcastStream<T>(this, onListen, onCancel);
- }
- StreamSubscription<T> listen(void onData(T event),
- {Function onError, void onDone(), bool cancelOnError});
- Stream<T> where(bool test(T event)) {
- return new _WhereStream<T>(this, test);
- }
- Stream map(convert(T event)) {
- return new _MapStream<T, dynamic>(this, convert);
- }
- Stream asyncMap(convert(T event)) {
- StreamController controller;
- StreamSubscription subscription;
- void onListen() {
- final add = controller.add;
- assert(controller is _StreamController ||
- controller is _BroadcastStreamController);
- final eventSink = controller;
- final addError = eventSink._addError;
- subscription = this.listen((T event) {
- var newValue;
- try {
- newValue = convert(event);
- } catch (e, s) {
- controller.addError(e, s);
- return;
- }
- if (newValue is Future) {
- subscription.pause();
- newValue
- .then(add, onError: addError)
- .whenComplete(subscription.resume);
- } else {
- controller.add(newValue);
+ startPeriodicTimer();
+ sendEvent();
+ }
+ );
+ }
+ , onCancel: () {
+ if (timer != null) timer.cancel();
+ timer = null;
+ }
+ );
+ return controller.stream;
+ }
+ factory Stream.eventTransformed(Stream source, EventSink mapSink(EventSink<T> sink)) {
+ return ((__x43) => DDC$RT.cast(__x43, DDC$RT.type((_BoundSinkStream<dynamic, dynamic> _) {
+ }
+ ), DDC$RT.type((Stream<T> _) {
+ }
+ ), "CastExact", """line 216, column 12 of dart:async/stream.dart: """, __x43 is Stream<T>, false))(new _BoundSinkStream(source, mapSink));
+ }
+ bool get isBroadcast => false;
+ Stream<T> asBroadcastStream({
+ void onListen(StreamSubscription<T> subscription), void onCancel(StreamSubscription<T> subscription)}
+) {
+ return new _AsBroadcastStream<T>(this, onListen, onCancel);
+ }
+ StreamSubscription<T> listen(void onData(T event), {
+ Function onError, void onDone(), bool cancelOnError}
+);
+ Stream<T> where(bool test(T event)) {
+ return new _WhereStream<T>(this, test);
+ }
+ Stream map(convert(T event)) {
+ return new _MapStream<T, dynamic>(this, convert);
+ }
+ Stream asyncMap(convert(T event)) {
+ StreamController controller;
+ StreamSubscription subscription;
+ void onListen() {
+ final add = controller.add;
+ assert (controller is _StreamController || controller is _BroadcastStreamController); final eventSink = controller;
+ final addError = eventSink._addError;
+ subscription = this.listen((T event) {
+ var newValue;
+ try {
+ newValue = convert(event);
}
- },
- onError: DDC$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: () {
- subscription.cancel();
- }, sync: true);
- } else {
- controller = new StreamController(onListen: onListen, onPause: () {
+ catch (e, s) {
+ controller.addError(e, s);
+ return;}
+ if (newValue is Future) {
subscription.pause();
- }, onResume: () {
- subscription.resume();
- }, onCancel: () {
- subscription.cancel();
- }, sync: true);
- }
- return controller.stream;
- }
- Stream asyncExpand(Stream convert(T event)) {
- StreamController controller;
- StreamSubscription subscription;
- void onListen() {
- assert(controller is _StreamController ||
- controller is _BroadcastStreamController);
- final eventSink = controller;
- subscription = this.listen((T event) {
- Stream newStream;
- try {
- newStream = convert(event);
- } catch (e, s) {
- controller.addError(e, s);
- return;
+ newValue.then(add, onError: addError).whenComplete(subscription.resume);
+ }
+ else {
+ controller.add(newValue);
}
- if (newStream != null) {
- subscription.pause();
- controller.addStream(newStream).whenComplete(subscription.resume);
+ }
+ , onError: DDC$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: () {
+ subscription.cancel();
+ }
+ , sync: true);
+ }
+ else {
+ controller = new StreamController(onListen: onListen, onPause: () {
+ subscription.pause();
+ }
+ , onResume: () {
+ subscription.resume();
+ }
+ , onCancel: () {
+ subscription.cancel();
+ }
+ , sync: true);
+ }
+ return controller.stream;
+ }
+ Stream asyncExpand(Stream convert(T event)) {
+ StreamController controller;
+ StreamSubscription subscription;
+ void onListen() {
+ assert (controller is _StreamController || controller is _BroadcastStreamController); final eventSink = controller;
+ subscription = this.listen((T event) {
+ Stream newStream;
+ try {
+ newStream = convert(event);
}
- },
- 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);
- }
- if (this.isBroadcast) {
- controller = new StreamController.broadcast(
- onListen: onListen, onCancel: () {
- subscription.cancel();
- }, sync: true);
- } else {
- controller = new StreamController(onListen: onListen, onPause: () {
+ catch (e, s) {
+ controller.addError(e, s);
+ return;}
+ if (newStream != null) {
subscription.pause();
- }, onResume: () {
- subscription.resume();
- }, onCancel: () {
- subscription.cancel();
- }, sync: true);
- }
- return controller.stream;
- }
- Stream<T> handleError(Function onError, {bool test(error)}) {
- return new _HandleErrorStream<T>(this, onError, test);
- }
- Stream expand(Iterable convert(T value)) {
- return new _ExpandStream<T, dynamic>(this, convert);
- }
- Future pipe(StreamConsumer<T> streamConsumer) {
- return streamConsumer.addStream(this).then((_) => streamConsumer.close());
- }
- Stream transform(StreamTransformer<T, dynamic> streamTransformer) {
- return streamTransformer.bind(this);
- }
- Future<T> reduce(T combine(T previous, T element)) {
- _Future<T> result = new _Future<T>();
- bool seenFirst = false;
- T value;
- StreamSubscription subscription;
- subscription = this.listen((T element) {
- if (seenFirst) {
- _runUserCode(() => combine(value, element), ((__x49) => DDC$RT.wrap(
- (dynamic f(T __u44)) {
- 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));
- return f == null ? null : c;
- }, __x49, DDC$RT.type((__t47<T> _) {}), __t45, "WrapLiteral",
- """line 500, column 24 of dart:async/stream.dart: """,
- __x49 is __t45))((T newValue) {
- value = newValue;
- }), ((__x53) => DDC$RT.cast(__x53, dynamic, __t50, "CastGeneral",
- """line 501, column 24 of dart:async/stream.dart: """,
- __x53 is __t50,
- false))(_cancelAndErrorClosure(subscription, result)));
- } else {
- value = element;
- seenFirst = true;
- }
- }, onError: result._completeError, onDone: () {
- if (!seenFirst) {
- try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(result, e, s);
+ 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);
+ }
+ if (this.isBroadcast) {
+ controller = new StreamController.broadcast(onListen: onListen, onCancel: () {
+ subscription.cancel();
+ }
+ , sync: true);
+ }
+ else {
+ controller = new StreamController(onListen: onListen, onPause: () {
+ subscription.pause();
+ }
+ , onResume: () {
+ subscription.resume();
+ }
+ , onCancel: () {
+ subscription.cancel();
+ }
+ , sync: true);
+ }
+ return controller.stream;
+ }
+ Stream<T> handleError(Function onError, {
+ bool test(error)}
+) {
+ return new _HandleErrorStream<T>(this, onError, test);
+ }
+ Stream expand(Iterable convert(T value)) {
+ return new _ExpandStream<T, dynamic>(this, convert);
+ }
+ Future pipe(StreamConsumer<T> streamConsumer) {
+ return streamConsumer.addStream(this).then((_) => streamConsumer.close());
+ }
+ Stream transform(StreamTransformer<T, dynamic> streamTransformer) {
+ return streamTransformer.bind(this);
+ }
+ Future<T> reduce(T combine(T previous, T element)) {
+ _Future<T> result = new _Future<T>();
+ bool seenFirst = false;
+ T value;
+ StreamSubscription subscription;
+ subscription = this.listen((T element) {
+ if (seenFirst) {
+ _runUserCode(() => combine(value, element), ((__x49) => DDC$RT.wrap((dynamic f(T __u44)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x49, DDC$RT.type((__t47<T> _) {
}
- } else {
- result._complete(value);
- }
- }, cancelOnError: true);
- return result;
- }
- Future fold(var initialValue, combine(var previous, T element)) {
- _Future result = new _Future();
- var value = initialValue;
- StreamSubscription subscription;
- subscription = this.listen((T element) {
- _runUserCode(() => combine(value, element), (newValue) {
+ ), __t45, "WrapLiteral", """line 500, column 24 of dart:async/stream.dart: """, __x49 is __t45))((T newValue) {
value = newValue;
- }, ((__x54) => DDC$RT.cast(__x54, dynamic, __t50, "CastGeneral",
- """line 534, column 11 of dart:async/stream.dart: """, __x54 is __t50,
- 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));
- }, onDone: () {
- result._complete(value);
- }, cancelOnError: true);
- return result;
- }
- Future<String> join([String separator = ""]) {
- _Future<String> result = new _Future<String>();
- StringBuffer buffer = new StringBuffer();
- StreamSubscription subscription;
- bool first = true;
- subscription = this.listen((T element) {
- if (!first) {
- buffer.write(separator);
- }
- first = false;
+ }
+ ), ((__x53) => DDC$RT.cast(__x53, dynamic, __t50, "CastGeneral", """line 501, column 24 of dart:async/stream.dart: """, __x53 is __t50, false))(_cancelAndErrorClosure(subscription, result)));
+ }
+ else {
+ value = element;
+ seenFirst = true;
+ }
+ }
+ , onError: result._completeError, onDone: () {
+ if (!seenFirst) {
try {
- buffer.write(element);
- } catch (e, s) {
- _cancelAndErrorWithReplacement(subscription, result, e, s);
- }
- }, onError: (e) {
- result._completeError(e);
- }, onDone: () {
- result._complete(buffer.toString());
- }, cancelOnError: true);
- return result;
- }
- Future<bool> contains(Object needle) {
- _Future<bool> future = new _Future<bool>();
- StreamSubscription subscription;
- subscription = this.listen((T element) {
- _runUserCode(() => (element == needle), ((__x58) => DDC$RT.wrap(
- (dynamic f(bool __u55)) {
- 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));
- return f == null ? null : c;
- }, __x58, __t56, __t45, "WrapLiteral",
- """line 597, column 13 of dart:async/stream.dart: """,
- __x58 is __t45))((bool isMatch) {
- if (isMatch) {
- _cancelAndValue(subscription, future, true);
+ throw IterableElementError.noElement();
}
- }), ((__x59) => DDC$RT.cast(__x59, dynamic, __t50, "CastGeneral",
- """line 602, column 13 of dart:async/stream.dart: """, __x59 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- future._complete(false);
- }, cancelOnError: true);
- return future;
- }
- Future forEach(void action(T element)) {
- _Future future = new _Future();
- StreamSubscription subscription;
- subscription = this.listen((T element) {
- _runUserCode(() => action(element), (_) {}, ((__x60) => DDC$RT.cast(__x60,
- dynamic, __t50, "CastGeneral",
- """line 628, column 13 of dart:async/stream.dart: """, __x60 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- future._complete(null);
- }, cancelOnError: true);
- return future;
- }
- Future<bool> every(bool test(T element)) {
- _Future<bool> future = new _Future<bool>();
- StreamSubscription subscription;
- subscription = this.listen((T element) {
- _runUserCode(() => test(element), ((__x62) => DDC$RT.wrap(
- (dynamic f(bool __u61)) {
- 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));
- return f == null ? null : c;
- }, __x62, __t56, __t45, "WrapLiteral",
- """line 652, column 13 of dart:async/stream.dart: """,
- __x62 is __t45))((bool isMatch) {
- if (!isMatch) {
- _cancelAndValue(subscription, future, false);
+ catch (e, s) {
+ _completeWithErrorCallback(result, e, s);
}
- }), ((__x63) => DDC$RT.cast(__x63, dynamic, __t50, "CastGeneral",
- """line 657, column 13 of dart:async/stream.dart: """, __x63 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- future._complete(true);
- }, cancelOnError: true);
- return future;
- }
- Future<bool> any(bool test(T element)) {
- _Future<bool> future = new _Future<bool>();
- StreamSubscription subscription;
- subscription = this.listen((T element) {
- _runUserCode(() => test(element), ((__x65) => DDC$RT.wrap(
- (dynamic f(bool __u64)) {
- 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));
- return f == null ? null : c;
- }, __x65, __t56, __t45, "WrapLiteral",
- """line 689, column 13 of dart:async/stream.dart: """,
- __x65 is __t45))((bool isMatch) {
- if (isMatch) {
- _cancelAndValue(subscription, future, true);
+ }
+ else {
+ result._complete(value);
+ }
+ }
+ , cancelOnError: true);
+ return result;
+ }
+ Future fold(var initialValue, combine(var previous, T element)) {
+ _Future result = new _Future();
+ var value = initialValue;
+ StreamSubscription subscription;
+ subscription = this.listen((T element) {
+ _runUserCode(() => combine(value, element), (newValue) {
+ value = newValue;
+ }
+ , ((__x54) => DDC$RT.cast(__x54, dynamic, __t50, "CastGeneral", """line 534, column 11 of dart:async/stream.dart: """, __x54 is __t50, 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));
+ }
+ , onDone: () {
+ result._complete(value);
+ }
+ , cancelOnError: true);
+ return result;
+ }
+ Future<String> join([String separator = ""]) {
+ _Future<String> result = new _Future<String>();
+ StringBuffer buffer = new StringBuffer();
+ StreamSubscription subscription;
+ bool first = true;
+ subscription = this.listen((T element) {
+ if (!first) {
+ buffer.write(separator);
+ }
+ first = false;
+ try {
+ buffer.write(element);
+ }
+ catch (e, s) {
+ _cancelAndErrorWithReplacement(subscription, result, e, s);
+ }
+ }
+ , onError: (e) {
+ result._completeError(e);
+ }
+ , onDone: () {
+ result._complete(buffer.toString());
+ }
+ , cancelOnError: true);
+ return result;
+ }
+ Future<bool> contains(Object needle) {
+ _Future<bool> future = new _Future<bool>();
+ StreamSubscription subscription;
+ subscription = this.listen((T element) {
+ _runUserCode(() => (element == needle), ((__x58) => DDC$RT.wrap((dynamic f(bool __u55)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x58, __t56, __t45, "WrapLiteral", """line 597, column 13 of dart:async/stream.dart: """, __x58 is __t45))((bool isMatch) {
+ if (isMatch) {
+ _cancelAndValue(subscription, future, true);
}
- }), ((__x66) => DDC$RT.cast(__x66, dynamic, __t50, "CastGeneral",
- """line 694, column 13 of dart:async/stream.dart: """, __x66 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- future._complete(false);
- }, cancelOnError: true);
- return future;
- }
- Future<int> get length {
- _Future<int> future = new _Future<int>();
- int count = 0;
- this.listen((_) {
- count++;
- }, onError: future._completeError, onDone: () {
- future._complete(count);
- }, cancelOnError: true);
- return future;
- }
- Future<bool> get isEmpty {
- _Future<bool> future = new _Future<bool>();
- StreamSubscription subscription;
- subscription = this.listen((_) {
- _cancelAndValue(subscription, future, false);
- }, onError: future._completeError, onDone: () {
- future._complete(true);
- }, cancelOnError: true);
- return future;
- }
- Future<List<T>> toList() {
- List<T> result = <T>[];
- _Future<List<T>> future = new _Future<List<T>>();
- this.listen((T data) {
- result.add(data);
- }, onError: future._completeError, onDone: () {
- future._complete(result);
- }, cancelOnError: true);
- return future;
- }
- Future<Set<T>> toSet() {
- Set<T> result = new Set<T>();
- _Future<Set<T>> future = new _Future<Set<T>>();
- this.listen((T data) {
- result.add(data);
- }, onError: future._completeError, onDone: () {
+ }
+ ), ((__x59) => DDC$RT.cast(__x59, dynamic, __t50, "CastGeneral", """line 602, column 13 of dart:async/stream.dart: """, __x59 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(false);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future forEach(void action(T element)) {
+ _Future future = new _Future();
+ StreamSubscription subscription;
+ subscription = this.listen((T element) {
+ _runUserCode(() => action(element), (_) {
+ }
+ , ((__x60) => DDC$RT.cast(__x60, dynamic, __t50, "CastGeneral", """line 628, column 13 of dart:async/stream.dart: """, __x60 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(null);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<bool> every(bool test(T element)) {
+ _Future<bool> future = new _Future<bool>();
+ StreamSubscription subscription;
+ subscription = this.listen((T element) {
+ _runUserCode(() => test(element), ((__x62) => DDC$RT.wrap((dynamic f(bool __u61)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x62, __t56, __t45, "WrapLiteral", """line 652, column 13 of dart:async/stream.dart: """, __x62 is __t45))((bool isMatch) {
+ if (!isMatch) {
+ _cancelAndValue(subscription, future, false);
+ }
+ }
+ ), ((__x63) => DDC$RT.cast(__x63, dynamic, __t50, "CastGeneral", """line 657, column 13 of dart:async/stream.dart: """, __x63 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(true);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<bool> any(bool test(T element)) {
+ _Future<bool> future = new _Future<bool>();
+ StreamSubscription subscription;
+ subscription = this.listen((T element) {
+ _runUserCode(() => test(element), ((__x65) => DDC$RT.wrap((dynamic f(bool __u64)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x65, __t56, __t45, "WrapLiteral", """line 689, column 13 of dart:async/stream.dart: """, __x65 is __t45))((bool isMatch) {
+ if (isMatch) {
+ _cancelAndValue(subscription, future, true);
+ }
+ }
+ ), ((__x66) => DDC$RT.cast(__x66, dynamic, __t50, "CastGeneral", """line 694, column 13 of dart:async/stream.dart: """, __x66 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(false);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<int> get length {
+ _Future<int> future = new _Future<int>();
+ int count = 0;
+ this.listen((_) {
+ count++;
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(count);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<bool> get isEmpty {
+ _Future<bool> future = new _Future<bool>();
+ StreamSubscription subscription;
+ subscription = this.listen((_) {
+ _cancelAndValue(subscription, future, false);
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(true);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<List<T>> toList() {
+ List<T> result = <T> [];
+ _Future<List<T>> future = new _Future<List<T>>();
+ this.listen((T data) {
+ result.add(data);
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(result);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<Set<T>> toSet() {
+ Set<T> result = new Set<T>();
+ _Future<Set<T>> future = new _Future<Set<T>>();
+ this.listen((T data) {
+ result.add(data);
+ }
+ , onError: future._completeError, onDone: () {
+ future._complete(result);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future drain([var futureValue]) => listen(null, cancelOnError: true).asFuture(futureValue);
+ Stream<T> take(int count) {
+ return ((__x67) => DDC$RT.cast(__x67, DDC$RT.type((_TakeStream<dynamic> _) {
+ }
+ ), DDC$RT.type((Stream<T> _) {
+ }
+ ), "CastExact", """line 819, column 12 of dart:async/stream.dart: """, __x67 is Stream<T>, false))(new _TakeStream(this, count));
+ }
+ Stream<T> takeWhile(bool test(T element)) {
+ return ((__x68) => DDC$RT.cast(__x68, DDC$RT.type((_TakeWhileStream<dynamic> _) {
+ }
+ ), DDC$RT.type((Stream<T> _) {
+ }
+ ), "CastExact", """line 841, column 12 of dart:async/stream.dart: """, __x68 is Stream<T>, false))(new _TakeWhileStream(this, test));
+ }
+ Stream<T> skip(int count) {
+ return ((__x69) => DDC$RT.cast(__x69, DDC$RT.type((_SkipStream<dynamic> _) {
+ }
+ ), DDC$RT.type((Stream<T> _) {
+ }
+ ), "CastExact", """line 852, column 12 of dart:async/stream.dart: """, __x69 is Stream<T>, false))(new _SkipStream(this, count));
+ }
+ Stream<T> skipWhile(bool test(T element)) {
+ return ((__x70) => DDC$RT.cast(__x70, DDC$RT.type((_SkipWhileStream<dynamic> _) {
+ }
+ ), DDC$RT.type((Stream<T> _) {
+ }
+ ), "CastExact", """line 868, column 12 of dart:async/stream.dart: """, __x70 is Stream<T>, false))(new _SkipWhileStream(this, test));
+ }
+ Stream<T> distinct([bool equals(T previous, T next)]) {
+ return ((__x71) => DDC$RT.cast(__x71, DDC$RT.type((_DistinctStream<dynamic> _) {
+ }
+ ), DDC$RT.type((Stream<T> _) {
+ }
+ ), "CastExact", """line 885, column 12 of dart:async/stream.dart: """, __x71 is Stream<T>, false))(new _DistinctStream(this, equals));
+ }
+ Future<T> get first {
+ _Future<T> future = new _Future<T>();
+ StreamSubscription subscription;
+ subscription = this.listen((T value) {
+ _cancelAndValue(subscription, future, value);
+ }
+ , onError: future._completeError, onDone: () {
+ try {
+ throw IterableElementError.noElement();
+ }
+ catch (e, s) {
+ _completeWithErrorCallback(future, e, s);
+ }
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<T> get last {
+ _Future<T> future = new _Future<T>();
+ T result = ((__x72) => DDC$RT.cast(__x72, Null, T, "CastLiteral", """line 936, column 16 of dart:async/stream.dart: """, __x72 is T, false))(null);
+ bool foundResult = false;
+ StreamSubscription subscription;
+ subscription = this.listen((T value) {
+ foundResult = true;
+ result = value;
+ }
+ , onError: future._completeError, onDone: () {
+ if (foundResult) {
future._complete(result);
- }, cancelOnError: true);
- return future;
- }
- Future drain([var futureValue]) =>
- listen(null, cancelOnError: true).asFuture(futureValue);
- Stream<T> take(int count) {
- return ((__x67) => DDC$RT.cast(__x67,
- DDC$RT.type((_TakeStream<dynamic> _) {}), DDC$RT.type((Stream<T> _) {}),
- "CastExact", """line 819, column 12 of dart:async/stream.dart: """,
- __x67 is Stream<T>, false))(new _TakeStream(this, count));
- }
- Stream<T> takeWhile(bool test(T element)) {
- return ((__x68) => DDC$RT.cast(__x68,
- DDC$RT.type((_TakeWhileStream<dynamic> _) {}),
- DDC$RT.type((Stream<T> _) {}), "CastExact",
- """line 841, column 12 of dart:async/stream.dart: """,
- __x68 is Stream<T>, false))(new _TakeWhileStream(this, test));
- }
- Stream<T> skip(int count) {
- return ((__x69) => DDC$RT.cast(__x69,
- DDC$RT.type((_SkipStream<dynamic> _) {}), DDC$RT.type((Stream<T> _) {}),
- "CastExact", """line 852, column 12 of dart:async/stream.dart: """,
- __x69 is Stream<T>, false))(new _SkipStream(this, count));
- }
- Stream<T> skipWhile(bool test(T element)) {
- return ((__x70) => DDC$RT.cast(__x70,
- DDC$RT.type((_SkipWhileStream<dynamic> _) {}),
- DDC$RT.type((Stream<T> _) {}), "CastExact",
- """line 868, column 12 of dart:async/stream.dart: """,
- __x70 is Stream<T>, false))(new _SkipWhileStream(this, test));
- }
- Stream<T> distinct([bool equals(T previous, T next)]) {
- return ((__x71) => DDC$RT.cast(__x71,
- DDC$RT.type((_DistinctStream<dynamic> _) {}),
- DDC$RT.type((Stream<T> _) {}), "CastExact",
- """line 885, column 12 of dart:async/stream.dart: """,
- __x71 is Stream<T>, false))(new _DistinctStream(this, equals));
- }
- Future<T> get first {
- _Future<T> future = new _Future<T>();
- StreamSubscription subscription;
- subscription = this.listen((T value) {
- _cancelAndValue(subscription, future, value);
- }, onError: future._completeError, onDone: () {
- try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true);
- return future;
- }
- Future<T> get last {
- _Future<T> future = new _Future<T>();
- T result = ((__x72) => DDC$RT.cast(__x72, Null, T, "CastLiteral",
- """line 936, column 16 of dart:async/stream.dart: """, __x72 is T,
- false))(null);
- bool foundResult = false;
- StreamSubscription subscription;
- subscription = this.listen((T value) {
- foundResult = true;
- result = value;
- }, onError: future._completeError, onDone: () {
- if (foundResult) {
- future._complete(result);
- return;
+ return;}
+ try {
+ throw IterableElementError.noElement();
+ }
+ catch (e, s) {
+ _completeWithErrorCallback(future, e, s);
}
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<T> get single {
+ _Future<T> future = new _Future<T>();
+ T result = ((__x73) => DDC$RT.cast(__x73, Null, T, "CastLiteral", """line 970, column 16 of dart:async/stream.dart: """, __x73 is T, false))(null);
+ bool foundResult = false;
+ StreamSubscription subscription;
+ subscription = this.listen((T value) {
+ if (foundResult) {
try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true);
- return future;
- }
- Future<T> get single {
- _Future<T> future = new _Future<T>();
- T result = ((__x73) => DDC$RT.cast(__x73, Null, T, "CastLiteral",
- """line 970, column 16 of dart:async/stream.dart: """, __x73 is T,
- false))(null);
- bool foundResult = false;
- StreamSubscription subscription;
- subscription = this.listen((T value) {
- if (foundResult) {
- try {
- throw IterableElementError.tooMany();
- } catch (e, s) {
- _cancelAndErrorWithReplacement(subscription, future, e, s);
+ throw IterableElementError.tooMany();
+ }
+ catch (e, s) {
+ _cancelAndErrorWithReplacement(subscription, future, e, s);
}
- return;
+ return;}
+ foundResult = true;
+ result = value;
+ }
+ , onError: future._completeError, onDone: () {
+ if (foundResult) {
+ future._complete(result);
+ return;}
+ try {
+ throw IterableElementError.noElement();
}
- foundResult = true;
- result = value;
- }, onError: future._completeError, onDone: () {
- if (foundResult) {
- future._complete(result);
- return;
+ catch (e, s) {
+ _completeWithErrorCallback(future, e, s);
}
- try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true);
- return future;
- }
- Future<dynamic> firstWhere(bool test(T element), {Object defaultValue()}) {
- _Future<dynamic> future = new _Future();
- StreamSubscription subscription;
- subscription = this.listen((T value) {
- _runUserCode(() => test(value), ((__x75) => DDC$RT.wrap(
- (dynamic f(bool __u74)) {
- 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));
- return f == null ? null : c;
- }, __x75, __t56, __t45, "WrapLiteral",
- """line 1031, column 11 of dart:async/stream.dart: """,
- __x75 is __t45))((bool isMatch) {
- if (isMatch) {
- _cancelAndValue(subscription, future, value);
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<dynamic> firstWhere(bool test(T element), {
+ Object defaultValue()}
+) {
+ _Future<dynamic> future = new _Future();
+ StreamSubscription subscription;
+ subscription = this.listen((T value) {
+ _runUserCode(() => test(value), ((__x75) => DDC$RT.wrap((dynamic f(bool __u74)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x75, __t56, __t45, "WrapLiteral", """line 1031, column 11 of dart:async/stream.dart: """, __x75 is __t45))((bool isMatch) {
+ if (isMatch) {
+ _cancelAndValue(subscription, future, value);
}
- }), ((__x76) => DDC$RT.cast(__x76, dynamic, __t50, "CastGeneral",
- """line 1036, column 11 of dart:async/stream.dart: """,
- __x76 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- if (defaultValue != null) {
- _runUserCode(defaultValue, future._complete, future._completeError);
- return;
}
- try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true);
- return future;
- }
- Future<dynamic> lastWhere(bool test(T element), {Object defaultValue()}) {
- _Future<dynamic> future = new _Future();
- T result = ((__x77) => DDC$RT.cast(__x77, Null, T, "CastLiteral",
- """line 1064, column 16 of dart:async/stream.dart: """, __x77 is T,
- false))(null);
- bool foundResult = false;
- StreamSubscription subscription;
- subscription = this.listen((T value) {
- _runUserCode(() => true == test(value), ((__x79) => DDC$RT.wrap(
- (dynamic f(bool __u78)) {
- 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));
- return f == null ? null : c;
- }, __x79, __t56, __t45, "WrapLiteral",
- """line 1071, column 11 of dart:async/stream.dart: """,
- __x79 is __t45))((bool isMatch) {
- if (isMatch) {
- foundResult = true;
- result = value;
+ ), ((__x76) => DDC$RT.cast(__x76, dynamic, __t50, "CastGeneral", """line 1036, column 11 of dart:async/stream.dart: """, __x76 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ if (defaultValue != null) {
+ _runUserCode(defaultValue, future._complete, future._completeError);
+ return;}
+ try {
+ throw IterableElementError.noElement();
+ }
+ catch (e, s) {
+ _completeWithErrorCallback(future, e, s);
+ }
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<dynamic> lastWhere(bool test(T element), {
+ Object defaultValue()}
+) {
+ _Future<dynamic> future = new _Future();
+ T result = ((__x77) => DDC$RT.cast(__x77, Null, T, "CastLiteral", """line 1064, column 16 of dart:async/stream.dart: """, __x77 is T, false))(null);
+ bool foundResult = false;
+ StreamSubscription subscription;
+ subscription = this.listen((T value) {
+ _runUserCode(() => true == test(value), ((__x79) => DDC$RT.wrap((dynamic f(bool __u78)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x79, __t56, __t45, "WrapLiteral", """line 1071, column 11 of dart:async/stream.dart: """, __x79 is __t45))((bool isMatch) {
+ if (isMatch) {
+ foundResult = true;
+ result = value;
}
- }), ((__x80) => DDC$RT.cast(__x80, dynamic, __t50, "CastGeneral",
- """line 1077, column 11 of dart:async/stream.dart: """,
- __x80 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- if (foundResult) {
- future._complete(result);
- return;
- }
- if (defaultValue != null) {
- _runUserCode(defaultValue, future._complete, future._completeError);
- return;
}
- try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true);
- return future;
- }
- Future<T> singleWhere(bool test(T element)) {
- _Future<T> future = new _Future<T>();
- T result = ((__x81) => DDC$RT.cast(__x81, Null, T, "CastLiteral",
- """line 1108, column 16 of dart:async/stream.dart: """, __x81 is T,
- false))(null);
- bool foundResult = false;
- StreamSubscription subscription;
- subscription = this.listen((T value) {
- _runUserCode(() => true == test(value), ((__x83) => DDC$RT.wrap(
- (dynamic f(bool __u82)) {
- 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));
- return f == null ? null : c;
- }, __x83, __t56, __t45, "WrapLiteral",
- """line 1115, column 11 of dart:async/stream.dart: """,
- __x83 is __t45))((bool isMatch) {
- if (isMatch) {
- if (foundResult) {
- try {
- throw IterableElementError.tooMany();
- } catch (e, s) {
- _cancelAndErrorWithReplacement(subscription, future, e, s);
+ ), ((__x80) => DDC$RT.cast(__x80, dynamic, __t50, "CastGeneral", """line 1077, column 11 of dart:async/stream.dart: """, __x80 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ if (foundResult) {
+ future._complete(result);
+ return;}
+ if (defaultValue != null) {
+ _runUserCode(defaultValue, future._complete, future._completeError);
+ return;}
+ try {
+ throw IterableElementError.noElement();
+ }
+ catch (e, s) {
+ _completeWithErrorCallback(future, e, s);
+ }
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<T> singleWhere(bool test(T element)) {
+ _Future<T> future = new _Future<T>();
+ T result = ((__x81) => DDC$RT.cast(__x81, Null, T, "CastLiteral", """line 1108, column 16 of dart:async/stream.dart: """, __x81 is T, false))(null);
+ bool foundResult = false;
+ StreamSubscription subscription;
+ subscription = this.listen((T value) {
+ _runUserCode(() => true == test(value), ((__x83) => DDC$RT.wrap((dynamic f(bool __u82)) {
+ 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));
+ return f == null ? null : c;
+ }
+ , __x83, __t56, __t45, "WrapLiteral", """line 1115, column 11 of dart:async/stream.dart: """, __x83 is __t45))((bool isMatch) {
+ if (isMatch) {
+ if (foundResult) {
+ try {
+ throw IterableElementError.tooMany();
+ }
+ catch (e, s) {
+ _cancelAndErrorWithReplacement(subscription, future, e, s);
+ }
+ return;}
+ foundResult = true;
+ result = value;
+ }
+ }
+ ), ((__x84) => DDC$RT.cast(__x84, dynamic, __t50, "CastGeneral", """line 1129, column 11 of dart:async/stream.dart: """, __x84 is __t50, false))(_cancelAndErrorClosure(subscription, future)));
+ }
+ , onError: future._completeError, onDone: () {
+ if (foundResult) {
+ future._complete(result);
+ return;}
+ try {
+ throw IterableElementError.noElement();
+ }
+ catch (e, s) {
+ _completeWithErrorCallback(future, e, s);
+ }
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Future<T> elementAt(int index) {
+ if (index is! int || index < 0) throw new ArgumentError(index);
+ _Future<T> future = new _Future<T>();
+ StreamSubscription subscription;
+ int elementIndex = 0;
+ subscription = this.listen((T value) {
+ if (index == elementIndex) {
+ _cancelAndValue(subscription, future, value);
+ return;}
+ elementIndex += 1;
+ }
+ , onError: future._completeError, onDone: () {
+ future._completeError(new RangeError.index(index, this, "index", null, elementIndex));
+ }
+ , cancelOnError: true);
+ return future;
+ }
+ Stream timeout(Duration timeLimit, {
+ void onTimeout(EventSink sink)}
+) {
+ StreamController controller;
+ StreamSubscription<T> subscription;
+ Timer timer;
+ Zone zone;
+ Function timeout;
+ void onData(T event) {
+ timer.cancel();
+ controller.add(event);
+ timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t85, "CastGeneral", """line 1219, column 43 of dart:async/stream.dart: """, timeout is __t85, 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, __t85, "CastGeneral", """line 1227, column 43 of dart:async/stream.dart: """, timeout is __t85, false));
+ }
+ void onDone() {
+ timer.cancel();
+ controller.close();
+ }
+ void onListen() {
+ zone = Zone.current;
+ if (onTimeout == null) {
+ timeout = () {
+ controller.addError(new TimeoutException("No stream event", timeLimit), null);
+ }
+ ;
+ }
+ else {
+ onTimeout = zone.registerUnaryCallback(DDC$RT.wrap((void f(EventSink<dynamic> __u86)) {
+ void c(EventSink<dynamic> x0) => f(DDC$RT.cast(x0, dynamic, DDC$RT.type((EventSink<dynamic> _) {
+ }
+ ), "CastParam", """line 1245, column 48 of dart:async/stream.dart: """, x0 is EventSink<dynamic>, true));
+ return f == null ? null : c;
+ }
+ , onTimeout, __t87, __t45, "Wrap", """line 1245, column 48 of dart:async/stream.dart: """, onTimeout is __t45));
+ _ControllerEventSinkWrapper wrapper = new _ControllerEventSinkWrapper(null);
+ timeout = () {
+ wrapper._sink = controller;
+ zone.runUnaryGuarded(DDC$RT.wrap((void f(EventSink<dynamic> __u89)) {
+ void c(EventSink<dynamic> x0) => f(DDC$RT.cast(x0, dynamic, DDC$RT.type((EventSink<dynamic> _) {
}
- return;
+ ), "CastParam", """line 1250, column 32 of dart:async/stream.dart: """, x0 is EventSink<dynamic>, true));
+ return f == null ? null : c;
}
- foundResult = true;
- result = value;
+ , onTimeout, __t87, __t45, "Wrap", """line 1250, column 32 of dart:async/stream.dart: """, onTimeout is __t45), wrapper);
+ wrapper._sink = null;
}
- }), ((__x84) => DDC$RT.cast(__x84, dynamic, __t50, "CastGeneral",
- """line 1129, column 11 of dart:async/stream.dart: """,
- __x84 is __t50,
- false))(_cancelAndErrorClosure(subscription, future)));
- }, onError: future._completeError, onDone: () {
- if (foundResult) {
- future._complete(result);
- return;
+ ;
}
- try {
- throw IterableElementError.noElement();
- } catch (e, s) {
- _completeWithErrorCallback(future, e, s);
- }
- }, cancelOnError: true);
- return future;
- }
- Future<T> elementAt(int index) {
- if (index is! int || index < 0) throw new ArgumentError(index);
- _Future<T> future = new _Future<T>();
- StreamSubscription subscription;
- int elementIndex = 0;
- subscription = this.listen((T value) {
- if (index == elementIndex) {
- _cancelAndValue(subscription, future, value);
- return;
- }
- elementIndex += 1;
- }, onError: future._completeError, onDone: () {
- future._completeError(
- new RangeError.index(index, this, "index", null, elementIndex));
- }, cancelOnError: true);
- return future;
- }
- Stream timeout(Duration timeLimit, {void onTimeout(EventSink sink)}) {
- StreamController controller;
- StreamSubscription<T> subscription;
- Timer timer;
- Zone zone;
- Function timeout;
- void onData(T event) {
- timer.cancel();
- controller.add(event);
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t85,
- "CastGeneral", """line 1219, column 43 of dart:async/stream.dart: """,
- timeout is __t85, 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, __t85,
- "CastGeneral", """line 1227, column 43 of dart:async/stream.dart: """,
- timeout is __t85, false));
- }
- void onDone() {
- timer.cancel();
- controller.close();
- }
- void onListen() {
- zone = Zone.current;
- if (onTimeout == null) {
- timeout = () {
- controller.addError(
- new TimeoutException("No stream event", timeLimit), null);
- };
- } else {
- onTimeout = zone.registerUnaryCallback(DDC$RT.wrap(
- (void f(EventSink<dynamic> __u86)) {
- void c(EventSink<dynamic> x0) => f(DDC$RT.cast(x0, dynamic,
- DDC$RT.type((EventSink<dynamic> _) {}), "CastParam",
- """line 1245, column 48 of dart:async/stream.dart: """,
- x0 is EventSink<dynamic>, true));
- return f == null ? null : c;
- }, onTimeout, __t87, __t45, "Wrap",
- """line 1245, column 48 of dart:async/stream.dart: """,
- onTimeout is __t45));
- _ControllerEventSinkWrapper wrapper =
- new _ControllerEventSinkWrapper(null);
- timeout = () {
- wrapper._sink = controller;
- zone.runUnaryGuarded(DDC$RT.wrap((void f(EventSink<dynamic> __u89)) {
- void c(EventSink<dynamic> x0) => f(DDC$RT.cast(x0, dynamic,
- DDC$RT.type((EventSink<dynamic> _) {}), "CastParam",
- """line 1250, column 32 of dart:async/stream.dart: """,
- x0 is EventSink<dynamic>, true));
- return f == null ? null : c;
- }, onTimeout, __t87, __t45, "Wrap",
- """line 1250, column 32 of dart:async/stream.dart: """,
- onTimeout is __t45), wrapper);
- wrapper._sink = null;
- };
- }
- subscription = this.listen(onData, onError: onError, onDone: onDone);
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t85,
- "CastGeneral", """line 1256, column 43 of dart:async/stream.dart: """,
- timeout is __t85, false));
- }
- Future onCancel() {
- timer.cancel();
- Future result = subscription.cancel();
- subscription = null;
- return result;
- }
- controller = isBroadcast
- ? new _SyncBroadcastStreamController(onListen, onCancel)
- : new _SyncStreamController(onListen, () {
- timer.cancel();
- subscription.pause();
- }, () {
- subscription.resume();
- timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t85,
- "CastGeneral", """line 1275, column 53 of dart:async/stream.dart: """,
- timeout is __t85, false));
- }, onCancel);
- return controller.stream;
+ subscription = this.listen(onData, onError: onError, onDone: onDone);
+ timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t85, "CastGeneral", """line 1256, column 43 of dart:async/stream.dart: """, timeout is __t85, false));
+ }
+ Future onCancel() {
+ timer.cancel();
+ Future result = subscription.cancel();
+ subscription = null;
+ return result;
+ }
+ controller = isBroadcast ? new _SyncBroadcastStreamController(onListen, onCancel) : new _SyncStreamController(onListen, () {
+ timer.cancel();
+ subscription.pause();
+ }
+ , () {
+ subscription.resume();
+ timer = zone.createTimer(timeLimit, DDC$RT.cast(timeout, Function, __t85, "CastGeneral", """line 1275, column 53 of dart:async/stream.dart: """, timeout is __t85, false));
+ }
+ , onCancel);
+ return controller.stream;
}
}
-abstract class StreamSubscription<T> {
- Future cancel();
- void onData(void handleData(T data));
- void onError(Function handleError);
- void onDone(void handleDone());
- void pause([Future resumeSignal]);
- void resume();
- bool get isPaused;
- Future asFuture([var futureValue]);
+ abstract class StreamSubscription<T> {Future cancel();
+ void onData(void handleData(T data));
+ void onError(Function handleError);
+ void onDone(void handleDone());
+ void pause([Future resumeSignal]);
+ void resume();
+ bool get isPaused;
+ Future asFuture([var futureValue]);
}
-abstract class EventSink<T> implements Sink<T> {
- void add(T event);
- void addError(errorEvent, [StackTrace stackTrace]);
- void close();
+ abstract class EventSink<T> implements Sink<T> {void add(T event);
+ void addError(errorEvent, [StackTrace stackTrace]);
+ void close();
}
-class StreamView<T> extends Stream<T> {
- Stream<T> _stream;
- StreamView(this._stream);
- bool get isBroadcast => _stream.isBroadcast;
- Stream<T> asBroadcastStream({void onListen(StreamSubscription subscription),
- void onCancel(StreamSubscription subscription)}) =>
- _stream.asBroadcastStream(onListen: onListen, onCancel: onCancel);
- StreamSubscription<T> listen(void onData(T value),
- {Function onError, void onDone(), bool cancelOnError}) {
- return _stream.listen(onData,
- onError: onError, onDone: onDone, cancelOnError: cancelOnError);
- }
+ class StreamView<T> extends Stream<T> {Stream<T> _stream;
+ StreamView(this._stream);
+ bool get isBroadcast => _stream.isBroadcast;
+ Stream<T> asBroadcastStream({
+void onListen(StreamSubscription subscription), void onCancel(StreamSubscription subscription)}
+) => _stream.asBroadcastStream(onListen: onListen, onCancel: onCancel);
+ StreamSubscription<T> listen(void onData(T value), {
+Function onError, void onDone(), bool cancelOnError}
+) {
+return _stream.listen(onData, onError: onError, onDone: onDone, cancelOnError: cancelOnError);
}
-abstract class StreamConsumer<S> {
- Future addStream(Stream<S> stream);
- Future close();
}
-abstract class StreamSink<S> implements StreamConsumer<S>, EventSink<S> {
- Future close();
- Future get done;
+ abstract class StreamConsumer<S> {Future addStream(Stream<S> stream);
+ Future close();
}
-abstract class StreamTransformer<S, T> {
- const factory StreamTransformer(StreamSubscription<T> transformer(
- Stream<S> stream, bool cancelOnError)) = _StreamSubscriptionTransformer;
- factory StreamTransformer.fromHandlers(
- {void handleData(S data, EventSink<T> sink),
- void handleError(Object error, StackTrace stackTrace, EventSink<T> sink),
- void handleDone(EventSink<T> sink)}) = _StreamHandlerTransformer;
- Stream<T> bind(Stream<S> stream);
+ abstract class StreamSink<S> implements StreamConsumer<S>, EventSink<S> {Future close();
+ Future get done;
}
-abstract class StreamIterator<T> {
- factory StreamIterator(Stream<T> stream) =>
- new _StreamIteratorImpl<T>(stream);
- Future<bool> moveNext();
- T get current;
- Future cancel();
+ abstract class StreamTransformer<S, T> {const factory StreamTransformer(StreamSubscription<T> transformer(Stream<S> stream, bool cancelOnError)) = _StreamSubscriptionTransformer;
+ factory StreamTransformer.fromHandlers({
+void handleData(S data, EventSink<T> sink), void handleError(Object error, StackTrace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)}
+) = _StreamHandlerTransformer;
+ Stream<T> bind(Stream<S> stream);
+}
+ abstract class StreamIterator<T> {factory StreamIterator(Stream<T> stream) => new _StreamIteratorImpl<T>(stream);
+ Future<bool> moveNext();
+ T get current;
+ Future cancel();
+}
+ class _ControllerEventSinkWrapper<T> implements EventSink<T> {EventSink _sink;
+ _ControllerEventSinkWrapper(this._sink);
+ void add(T data) {
+_sink.add(data);
+}
+ void addError(error, [StackTrace stackTrace]) {
+_sink.addError(error, stackTrace);
+}
+ void close() {
+_sink.close();
}
-class _ControllerEventSinkWrapper<T> implements EventSink<T> {
- EventSink _sink;
- _ControllerEventSinkWrapper(this._sink);
- void add(T data) {
- _sink.add(data);
- }
- void addError(error, [StackTrace stackTrace]) {
- _sink.addError(error, stackTrace);
- }
- void close() {
- _sink.close();
- }
}
-typedef T __t38<T>(int __u39);
-typedef dynamic __t40(dynamic __u41);
-typedef dynamic __t45(dynamic __u46);
-typedef dynamic __t47<T>(T __u48);
-typedef dynamic __t50(dynamic __u51, StackTrace __u52);
-typedef dynamic __t56(bool __u57);
-typedef void __t85();
-typedef void __t87(EventSink<dynamic> __u88);
+ typedef T __t38<T>(int __u39);
+ typedef dynamic __t40(dynamic __u41);
+ typedef dynamic __t45(dynamic __u46);
+ typedef dynamic __t47<T>(T __u48);
+ typedef dynamic __t50(dynamic __u51, StackTrace __u52);
+ typedef dynamic __t56(bool __u57);
+ typedef void __t85();
+ typedef void __t87(EventSink<dynamic> __u88);
« test/dart_codegen/expect/_internal/iterable.dart ('K') | « 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