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

Side by Side Diff: test/dart_codegen/expect/async/stream_transformers.dart

Issue 1052383003: Disable closure wrapping by default (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: Created 5 years, 8 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 unified diff | Download patch
OLDNEW
1 part of dart.async; 1 part of dart.async;
2 class _EventSinkWrapper<T> implements EventSink<T> {_EventSink _sink; 2 class _EventSinkWrapper<T> implements EventSink<T> {_EventSink _sink;
3 _EventSinkWrapper(this._sink); 3 _EventSinkWrapper(this._sink);
4 void add(T data) { 4 void add(T data) {
5 _sink._add(data); 5 _sink._add(data);
6 } 6 }
7 void addError(error, [StackTrace stackTrace]) { 7 void addError(error, [StackTrace stackTrace]) {
8 _sink._addError(error, stackTrace); 8 _sink._addError(error, stackTrace);
9 } 9 }
10 void close() { 10 void close() {
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after
88 Stream<T> bind(Stream<S> stream) => new _BoundSinkStream<S, T>(stream, _sinkMap per); 88 Stream<T> bind(Stream<S> stream) => new _BoundSinkStream<S, T>(stream, _sinkMap per);
89 } 89 }
90 class _BoundSinkStream<S, T> extends Stream<T> {final _SinkMapper<S, T> _sinkMa pper; 90 class _BoundSinkStream<S, T> extends Stream<T> {final _SinkMapper<S, T> _sinkMa pper;
91 final Stream<S> _stream; 91 final Stream<S> _stream;
92 bool get isBroadcast => _stream.isBroadcast; 92 bool get isBroadcast => _stream.isBroadcast;
93 _BoundSinkStream(this._stream, this._sinkMapper); 93 _BoundSinkStream(this._stream, this._sinkMapper);
94 StreamSubscription<T> listen(void onData(T event), { 94 StreamSubscription<T> listen(void onData(T event), {
95 Function onError, void onDone(), bool cancelOnError} 95 Function onError, void onDone(), bool cancelOnError}
96 ) { 96 ) {
97 cancelOnError = identical(true, cancelOnError); 97 cancelOnError = identical(true, cancelOnError);
98 StreamSubscription<T> subscription = new _SinkTransformerStreamSubscription(_st ream, DEVC$RT.wrap((EventSink<S> f(EventSink<T> __u93)) { 98 StreamSubscription<T> subscription = new _SinkTransformerStreamSubscription(_st ream, DEVC$RT.cast(_sinkMapper, DEVC$RT.type((__t79<T, S> _) {
99 EventSink<S> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dy namic> _) {
100 } 99 }
101 ), DEVC$RT.type((EventSink<T> _) { 100 ), __t77, "CompositeCast", """line 187, column 18 of dart:async/stream_transform ers.dart: """, _sinkMapper is __t77, false), onData, onError, onDone, cancelOnEr ror);
102 }
103 ), "CastParam", """line 187, column 18 of dart:async/stream_transformers.dart: " "", x0 is EventSink<T>, false));
104 return f == null ? null : c;
105 }
106 , _sinkMapper, DEVC$RT.type((__t96<T, S> _) {
107 }
108 ), __t94, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart: """, _sinkMapper is __t94), onData, onError, onDone, cancelOnError);
109 return subscription; 101 return subscription;
110 } 102 }
111 } 103 }
112 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); 104 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink);
113 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve ntSink<T> sink); 105 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve ntSink<T> sink);
114 typedef void _TransformDoneHandler<T>(EventSink<T> sink); 106 typedef void _TransformDoneHandler<T>(EventSink<T> sink);
115 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand ler<S, T> _handleData; 107 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand ler<S, T> _handleData;
116 final _TransformErrorHandler<T> _handleError; 108 final _TransformErrorHandler<T> _handleError;
117 final _TransformDoneHandler<T> _handleDone; 109 final _TransformDoneHandler<T> _handleDone;
118 final EventSink<T> _sink; 110 final EventSink<T> _sink;
119 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink); 111 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink);
120 void add(S data) => _handleData(data, _sink); 112 void add(S data) => _handleData(data, _sink);
121 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink); 113 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink);
122 void close() => _handleDone(_sink); 114 void close() => _handleDone(_sink);
123 } 115 }
124 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({ 116 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({
125 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)} 117 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)}
126 ) : super(((__x104) => DEVC$RT.wrap((dynamic f(EventSink<T> __u99)) { 118 ) : super(((__x85) => DEVC$RT.cast(__x85, DEVC$RT.type((__t83<T> _) {
127 dynamic c(EventSink<T> x0) => ((__x98) => DEVC$RT.cast(__x98, dynamic, DEVC$RT.t ype((EventSink<S> _) {
128 } 119 }
129 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x98 is EventSink<S>, false))(f(x0)); 120 ), DEVC$RT.type((__t81<T, S> _) {
130 return f == null ? null : c;
131 } 121 }
132 , __x104, DEVC$RT.type((__t102<T> _) { 122 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers. dart: """, __x85 is __t81<T, S>, false))((EventSink<T> outputSink) {
123 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __t89, DEV C$RT.type((__t86<S, T> _) {
133 } 124 }
134 ), DEVC$RT.type((__t100<T, S> _) { 125 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar t: """, _defaultHandleData is __t86<S, T>, false);
126 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __t96, DEVC$RT.type((__t92<T> _) {
135 } 127 }
136 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x104 is __t100<T, S>))((EventSink<T> outputSink) { 128 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar t: """, _defaultHandleError is __t92<T>, false);
137 if (handleData == null) handleData = DEVC$RT.wrap((void f(dynamic __u105, EventS ink<dynamic> __u106)) {
138 void c(dynamic x0, EventSink<dynamic> x1) => f(x0, x1);
139 return f == null ? null : c;
140 }
141 , _defaultHandleData, __t110, DEVC$RT.type((__t107<S, T> _) {
142 }
143 ), "Wrap", """line 234, column 48 of dart:async/stream_transformers.dart: """, _ defaultHandleData is __t107<S, T>);
144 if (handleError == null) handleError = DEVC$RT.wrap((void f(dynamic __u113, Sta ckTrace __u114, EventSink<dynamic> __u115)) {
145 void c(dynamic x0, StackTrace x1, EventSink<dynamic> x2) => f(x0, x1, x2);
146 return f == null ? null : c;
147 }
148 , _defaultHandleError, __t120, DEVC$RT.type((__t116<T> _) {
149 }
150 ), "Wrap", """line 235, column 50 of dart:async/stream_transformers.dart: """, _ defaultHandleError is __t116<T>);
151 if (handleDone == null) handleDone = _defaultHandleDone; 129 if (handleDone == null) handleDone = _defaultHandleDone;
152 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink); 130 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink);
153 } 131 }
154 )); 132 ));
155 Stream<T> bind(Stream<S> stream) { 133 Stream<T> bind(Stream<S> stream) {
156 return super.bind(stream); 134 return super.bind(stream);
157 } 135 }
158 static void _defaultHandleData(var data, EventSink sink) { 136 static void _defaultHandleData(var data, EventSink sink) {
159 sink.add(data); 137 sink.add(data);
160 } 138 }
(...skipping 16 matching lines...) Expand all
177 Function onError, void onDone(), bool cancelOnError} 155 Function onError, void onDone(), bool cancelOnError}
178 ) { 156 ) {
179 cancelOnError = identical(true, cancelOnError); 157 cancelOnError = identical(true, cancelOnError);
180 StreamSubscription<T> result = _transformer(_stream, cancelOnError); 158 StreamSubscription<T> result = _transformer(_stream, cancelOnError);
181 result.onData(onData); 159 result.onData(onData);
182 result.onError(onError); 160 result.onError(onError);
183 result.onDone(onDone); 161 result.onDone(onDone);
184 return result; 162 return result;
185 } 163 }
186 } 164 }
187 typedef EventSink<dynamic> __t94(EventSink<dynamic> __u95); 165 typedef EventSink<dynamic> __t77(EventSink<dynamic> __u78);
188 typedef EventSink<S> __t96<T, S>(EventSink<T> __u97); 166 typedef EventSink<S> __t79<T, S>(EventSink<T> __u80);
189 typedef EventSink<S> __t100<T, S>(EventSink<T> __u101); 167 typedef EventSink<S> __t81<T, S>(EventSink<T> __u82);
190 typedef dynamic __t102<T>(EventSink<T> __u103); 168 typedef dynamic __t83<T>(EventSink<T> __u84);
191 typedef void __t107<S, T>(S __u108, EventSink<T> __u109); 169 typedef void __t86<S, T>(S __u87, EventSink<T> __u88);
192 typedef void __t110(dynamic __u111, EventSink<dynamic> __u112); 170 typedef void __t89(dynamic __u90, EventSink<dynamic> __u91);
193 typedef void __t116<T>(Object __u117, StackTrace __u118, EventSink<T> __u119); 171 typedef void __t92<T>(Object __u93, StackTrace __u94, EventSink<T> __u95);
194 typedef void __t120(dynamic __u121, StackTrace __u122, EventSink<dynamic> __u12 3); 172 typedef void __t96(dynamic __u97, StackTrace __u98, EventSink<dynamic> __u99);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698