Disable formatting and add new-lines to make tests faster.

test/dart_codegen/expect/async/stream_transformers.dart

 part of dart.async;
-
-class _EventSinkWrapper<T> implements EventSink<T> {
-  _EventSink _sink;
-  _EventSinkWrapper(this._sink);
-  void add(T data) {
-    _sink._add(data);
+ 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 addError(error, [StackTrace stackTrace]) {
+  _sink._addError(error, stackTrace);
   }
-  void close() {
-    _sink._close();
+ void close() {
+  _sink._close();
   }
 }
-class _SinkTransformerStreamSubscription<S, T>
-    extends _BufferingStreamSubscription<T> {
-  EventSink _transformerSink;
-  StreamSubscription<S> _subscription;
-  _SinkTransformerStreamSubscription(Stream<S> source, _SinkMapper 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);
+ class _SinkTransformerStreamSubscription<S, T> extends _BufferingStreamSubscription<T> {EventSink _transformerSink;
+ StreamSubscription<S> _subscription;
+ _SinkTransformerStreamSubscription(Stream<S> source, _SinkMapper 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");
   }
-  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, DDC$RT.cast(stackTrace, dynamic, StackTrace, "CastGeneral", """line 127, column 40 of dart:async/stream_transformers.dart: """, stackTrace is StackTrace, true));
+  }
+ catch (e, s) {
+  if (identical(e, error)) {
+    _addError(error, DDC$RT.cast(stackTrace, dynamic, StackTrace, "CastGeneral", """line 130, column 26 of dart:async/stream_transformers.dart: """, stackTrace is StackTrace, true));
     }
-    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, DDC$RT.cast(stackTrace, dynamic,
-          StackTrace, "CastGeneral",
-          """line 127, column 40 of dart:async/stream_transformers.dart: """,
-          stackTrace is StackTrace, true));
-    } catch (e, s) {
-      if (identical(e, error)) {
-        _addError(error, DDC$RT.cast(stackTrace, dynamic, StackTrace,
-            "CastGeneral",
-            """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);
+   else {
+    _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 = ((__x118) => DDC$RT.cast(__x118,
-            DDC$RT.type(
-                (_SinkTransformerStreamSubscription<dynamic, dynamic> _) {}),
-            DDC$RT.type((StreamSubscription<T> _) {}), "CastExact",
-            """line 186, column 42 of dart:async/stream_transformers.dart: """,
-            __x118 is StreamSubscription<T>, false))(
-        new _SinkTransformerStreamSubscription(
-            _stream, _sinkMapper, onData, onError, onDone, cancelOnError));
-    return subscription;
+ void _handleDone() {
+try {
+  _subscription = null;
+   _transformerSink.close();
+  }
+ catch (e, s) {
+  _addError(e, s);
   }
 }
-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(((__x125) => DDC$RT.wrap((dynamic f(EventSink<T> __u120)) {
-        dynamic c(EventSink<T> x0) => ((__x119) => DDC$RT.cast(__x119, dynamic,
-            DDC$RT.type((EventSink<S> _) {}), "CastResult",
-            """line 233, column 15 of dart:async/stream_transformers.dart: """,
-            __x119 is EventSink<S>, false))(f(x0));
-        return f == null ? null : c;
-      }, __x125, DDC$RT.type((__t123<T> _) {}),
-          DDC$RT.type((__t121<T, S> _) {}), "WrapLiteral",
-          """line 233, column 15 of dart:async/stream_transformers.dart: """,
-          __x125 is __t121<T, S>))((EventSink<T> outputSink) {
-        if (handleData == null) handleData = _defaultHandleData;
-        if (handleError == null) handleError = _defaultHandleError;
-        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 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);
 }
-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 _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 = ((__x118) => DDC$RT.cast(__x118, DDC$RT.type((_SinkTransformerStreamSubscription<dynamic, dynamic> _) {
 }
-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;
-  }
+), DDC$RT.type((StreamSubscription<T> _) {
 }
-typedef EventSink<S> __t121<T, S>(EventSink<T> __u122);
-typedef dynamic __t123<T>(EventSink<T> __u124);
+), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: """, __x118 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscription(_stream, _sinkMapper, 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(((__x125) => DDC$RT.wrap((dynamic f(EventSink<T> __u120)) {
+dynamic c(EventSink<T> x0) => ((__x119) => DDC$RT.cast(__x119, dynamic, DDC$RT.type((EventSink<S> _) {
+}
+), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x119 is EventSink<S>, false))(f(x0));
+ return f == null ? null : c;
+}
+, __x125, DDC$RT.type((__t123<T> _) {
+}
+), DDC$RT.type((__t121<T, S> _) {
+}
+), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x125 is __t121<T, S>))((EventSink<T> outputSink) {
+if (handleData == null) handleData = _defaultHandleData;
+ if (handleError == null) handleError = _defaultHandleError;
+ 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 EventSink<S> __t121<T, S>(EventSink<T> __u122);
+ typedef dynamic __t123<T>(EventSink<T> __u124);