| Index: test/dart_codegen/expect/async/stream_transformers.dart
|
| diff --git a/test/dart_codegen/expect/async/stream_transformers.dart b/test/dart_codegen/expect/async/stream_transformers.dart
|
| deleted file mode 100644
|
| index d1fddb575974e49870e89c7201f6e8d187d87747..0000000000000000000000000000000000000000
|
| --- a/test/dart_codegen/expect/async/stream_transformers.dart
|
| +++ /dev/null
|
| @@ -1,171 +0,0 @@
|
| -part of dart.async;
|
| - class _EventSinkWrapper<T> implements EventSink<T> {_EventSink _sink;
|
| - _EventSinkWrapper(this._sink);
|
| - void add(T data) {
|
| - _sink._add(data);
|
| - }
|
| - void addError(error, [StackTrace stackTrace]) {
|
| - _sink._addError(error, stackTrace);
|
| - }
|
| - void close() {
|
| - _sink._close();
|
| - }
|
| -}
|
| - class _SinkTransformerStreamSubscription<S, T> extends _BufferingStreamSubscription<T> {EventSink _transformerSink;
|
| - StreamSubscription<S> _subscription;
|
| - _SinkTransformerStreamSubscription(Stream<S> source, _SinkMapper<S, T> mapper, void onData(T data), Function onError, void onDone(), bool cancelOnError) : super(onData, onError, onDone, cancelOnError) {
|
| -_EventSinkWrapper<T> eventSink = new _EventSinkWrapper<T>(this);
|
| - _transformerSink = mapper(eventSink);
|
| - _subscription = source.listen(_handleData, onError: _handleError, onDone: _handleDone);
|
| -}
|
| - bool get _isSubscribed => _subscription != null;
|
| - void _add(T data) {
|
| -if (_isClosed) {
|
| - throw new StateError("Stream is already closed");
|
| - }
|
| - super._add(data);
|
| -}
|
| - void _addError(Object error, StackTrace stackTrace) {
|
| -if (_isClosed) {
|
| - throw new StateError("Stream is already closed");
|
| - }
|
| - super._addError(error, stackTrace);
|
| -}
|
| - void _close() {
|
| -if (_isClosed) {
|
| - throw new StateError("Stream is already closed");
|
| - }
|
| - super._close();
|
| -}
|
| - void _onPause() {
|
| -if (_isSubscribed) _subscription.pause();
|
| -}
|
| - void _onResume() {
|
| -if (_isSubscribed) _subscription.resume();
|
| -}
|
| - Future _onCancel() {
|
| -if (_isSubscribed) {
|
| - StreamSubscription subscription = _subscription;
|
| - _subscription = null;
|
| - subscription.cancel();
|
| - }
|
| - return null;
|
| -}
|
| - void _handleData(S data) {
|
| -try {
|
| - _transformerSink.add(data);
|
| - }
|
| - catch (e, s) {
|
| - _addError(e, s);
|
| - }
|
| -}
|
| - void _handleError(error, [stackTrace]) {
|
| -try {
|
| - _transformerSink.addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "DynamicCast", """line 127, column 40 of dart:async/stream_transformers.dart: """, stackTrace is StackTrace, true));
|
| - }
|
| - catch (e, s) {
|
| - if (identical(e, error)) {
|
| - _addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "DynamicCast", """line 130, column 26 of dart:async/stream_transformers.dart: """, stackTrace is StackTrace, true));
|
| - }
|
| - else {
|
| - _addError(e, s);
|
| - }
|
| - }
|
| -}
|
| - void _handleDone() {
|
| -try {
|
| - _subscription = null;
|
| - _transformerSink.close();
|
| - }
|
| - catch (e, s) {
|
| - _addError(e, s);
|
| - }
|
| -}
|
| -}
|
| - typedef EventSink<S> _SinkMapper<S, T>(EventSink<T> output);
|
| - class _StreamSinkTransformer<S, T> implements StreamTransformer<S, T> {final _SinkMapper<S, T> _sinkMapper;
|
| - const _StreamSinkTransformer(this._sinkMapper);
|
| - Stream<T> bind(Stream<S> stream) => new _BoundSinkStream<S, T>(stream, _sinkMapper);
|
| -}
|
| - class _BoundSinkStream<S, T> extends Stream<T> {final _SinkMapper<S, T> _sinkMapper;
|
| - final Stream<S> _stream;
|
| - bool get isBroadcast => _stream.isBroadcast;
|
| - _BoundSinkStream(this._stream, this._sinkMapper);
|
| - StreamSubscription<T> listen(void onData(T event), {
|
| -Function onError, void onDone(), bool cancelOnError}
|
| -) {
|
| -cancelOnError = identical(true, cancelOnError);
|
| - StreamSubscription<T> subscription = new _SinkTransformerStreamSubscription<dynamic, T>(_stream, DEVC$RT.cast(_sinkMapper, DEVC$RT.type((_SinkMapper<S, T> _) {
|
| -}
|
| -), DEVC$RT.type((_SinkMapper<dynamic, dynamic> _) {
|
| -}
|
| -), "CompositeCast", """line 187, column 18 of dart:async/stream_transformers.dart: """, _sinkMapper is _SinkMapper<dynamic, dynamic>, false), onData, onError, onDone, cancelOnError);
|
| - return subscription;
|
| -}
|
| -}
|
| - typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink);
|
| - typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, EventSink<T> sink);
|
| - typedef void _TransformDoneHandler<T>(EventSink<T> sink);
|
| - class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHandler<S, T> _handleData;
|
| - final _TransformErrorHandler<T> _handleError;
|
| - final _TransformDoneHandler<T> _handleDone;
|
| - final EventSink<T> _sink;
|
| - _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._sink);
|
| - void add(S data) => _handleData(data, _sink);
|
| - void addError(Object error, [StackTrace stackTrace]) => _handleError(error, stackTrace, _sink);
|
| - void close() => _handleDone(_sink);
|
| -}
|
| - class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_StreamHandlerTransformer({
|
| -void handleData(S data, EventSink<T> sink), void handleError(Object error, StackTrace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)}
|
| -) : super(((__x61) => DEVC$RT.cast(__x61, DEVC$RT.type((__CastType59<T> _) {
|
| -}
|
| -), DEVC$RT.type((_SinkMapper<S, T> _) {
|
| -}
|
| -), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x61 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) {
|
| -if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __CastType65, DEVC$RT.type((__CastType62<S, T> _) {
|
| -}
|
| -), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dart: """, _defaultHandleData is __CastType62<S, T>, false);
|
| - if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __CastType72, DEVC$RT.type((__CastType68<T> _) {
|
| -}
|
| -), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dart: """, _defaultHandleError is __CastType68<T>, false);
|
| - if (handleDone == null) handleDone = _defaultHandleDone;
|
| - return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputSink);
|
| -}
|
| -));
|
| - Stream<T> bind(Stream<S> stream) {
|
| -return super.bind(stream);
|
| -}
|
| - static void _defaultHandleData(var data, EventSink sink) {
|
| -sink.add(data);
|
| -}
|
| - static void _defaultHandleError(error, StackTrace stackTrace, EventSink sink) {
|
| -sink.addError(error);
|
| -}
|
| - static void _defaultHandleDone(EventSink sink) {
|
| -sink.close();
|
| -}
|
| -}
|
| - typedef StreamSubscription<T> _SubscriptionTransformer<S, T>(Stream<S> stream, bool cancelOnError);
|
| - class _StreamSubscriptionTransformer<S, T> implements StreamTransformer<S, T> {final _SubscriptionTransformer<S, T> _transformer;
|
| - const _StreamSubscriptionTransformer(this._transformer);
|
| - Stream<T> bind(Stream<S> stream) => new _BoundSubscriptionStream<S, T>(stream, _transformer);
|
| -}
|
| - class _BoundSubscriptionStream<S, T> extends Stream<T> {final _SubscriptionTransformer<S, T> _transformer;
|
| - final Stream<S> _stream;
|
| - _BoundSubscriptionStream(this._stream, this._transformer);
|
| - StreamSubscription<T> listen(void onData(T event), {
|
| -Function onError, void onDone(), bool cancelOnError}
|
| -) {
|
| -cancelOnError = identical(true, cancelOnError);
|
| - StreamSubscription<T> result = _transformer(_stream, cancelOnError);
|
| - result.onData(onData);
|
| - result.onError(onError);
|
| - result.onDone(onDone);
|
| - return result;
|
| -}
|
| -}
|
| - typedef dynamic __CastType59<T>(EventSink<T> __u60);
|
| - typedef void __CastType62<S, T>(S __u63, EventSink<T> __u64);
|
| - typedef void __CastType65(dynamic __u66, EventSink<dynamic> __u67);
|
| - typedef void __CastType68<T>(Object __u69, StackTrace __u70, EventSink<T> __u71);
|
| - typedef void __CastType72(dynamic __u73, StackTrace __u74, EventSink<dynamic> __u75);
|
|
|