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

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

Issue 959003003: Typecheck constructor initializers properly (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: Rebase Created 5 years, 9 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 = ((__x118) => DDC$RT.cast(__x118, DDC$RT.ty pe((_SinkTransformerStreamSubscription<dynamic, dynamic> _) { 98 StreamSubscription<T> subscription = ((__x158) => DDC$RT.cast(__x158, DDC$RT.ty pe((_SinkTransformerStreamSubscription<dynamic, dynamic> _) {
99 } 99 }
100 ), DDC$RT.type((StreamSubscription<T> _) { 100 ), DDC$RT.type((StreamSubscription<T> _) {
101 } 101 }
102 ), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: " "", __x118 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript ion(_stream, _sinkMapper, onData, onError, onDone, cancelOnError)); 102 ), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: " "", __x158 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript ion(_stream, DDC$RT.wrap((EventSink<S> f(EventSink<T> __u159)) {
103 EventSink<S> c(EventSink<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((EventSink<dyna mic> _) {
104 }
105 ), DDC$RT.type((EventSink<T> _) {
106 }
107 ), "CastParam", """line 187, column 18 of dart:async/stream_transformers.dart: " "", x0 is EventSink<T>, false));
108 return f == null ? null : c;
109 }
110 , _sinkMapper, DDC$RT.type((__t162<T, S> _) {
111 }
112 ), __t160, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart : """, _sinkMapper is __t160), DDC$RT.wrap((void f(T __u164)) {
113 void c(T x0) => f(DDC$RT.cast(x0, dynamic, T, "CastParam", """line 187, column 3 1 of dart:async/stream_transformers.dart: """, x0 is T, false));
114 return f == null ? null : c;
115 }
116 , onData, DDC$RT.type((__t167<T> _) {
117 }
118 ), __t165, "Wrap", """line 187, column 31 of dart:async/stream_transformers.dart : """, onData is __t165), onError, onDone, cancelOnError));
103 return subscription; 119 return subscription;
104 } 120 }
105 } 121 }
106 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); 122 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink);
107 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve ntSink<T> sink); 123 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve ntSink<T> sink);
108 typedef void _TransformDoneHandler<T>(EventSink<T> sink); 124 typedef void _TransformDoneHandler<T>(EventSink<T> sink);
109 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand ler<S, T> _handleData; 125 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand ler<S, T> _handleData;
110 final _TransformErrorHandler<T> _handleError; 126 final _TransformErrorHandler<T> _handleError;
111 final _TransformDoneHandler<T> _handleDone; 127 final _TransformDoneHandler<T> _handleDone;
112 final EventSink<T> _sink; 128 final EventSink<T> _sink;
113 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink); 129 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink);
114 void add(S data) => _handleData(data, _sink); 130 void add(S data) => _handleData(data, _sink);
115 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink); 131 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink);
116 void close() => _handleDone(_sink); 132 void close() => _handleDone(_sink);
117 } 133 }
118 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({ 134 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({
119 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)} 135 void handleData(S data, EventSink<T> sink), void handleError(Object error, Stack Trace stackTrace, EventSink<T> sink), void handleDone(EventSink<T> sink)}
120 ) : super(((__x125) => DDC$RT.wrap((dynamic f(EventSink<T> __u120)) { 136 ) : super(((__x175) => DDC$RT.wrap((dynamic f(EventSink<T> __u170)) {
121 dynamic c(EventSink<T> x0) => ((__x119) => DDC$RT.cast(__x119, dynamic, DDC$RT.t ype((EventSink<S> _) { 137 dynamic c(EventSink<T> x0) => ((__x169) => DDC$RT.cast(__x169, dynamic, DDC$RT.t ype((EventSink<S> _) {
122 } 138 }
123 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x119 is EventSink<S>, false))(f(x0)); 139 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x169 is EventSink<S>, false))(f(x0));
124 return f == null ? null : c; 140 return f == null ? null : c;
125 } 141 }
126 , __x125, DDC$RT.type((__t123<T> _) { 142 , __x175, DDC$RT.type((__t173<T> _) {
127 } 143 }
128 ), DDC$RT.type((__t121<T, S> _) { 144 ), DDC$RT.type((__t171<T, S> _) {
129 } 145 }
130 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x125 is __t121<T, S>))((EventSink<T> outputSink) { 146 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x175 is __t171<T, S>))((EventSink<T> outputSink) {
131 if (handleData == null) handleData = _defaultHandleData; 147 if (handleData == null) handleData = _defaultHandleData;
132 if (handleError == null) handleError = _defaultHandleError; 148 if (handleError == null) handleError = _defaultHandleError;
133 if (handleDone == null) handleDone = _defaultHandleDone; 149 if (handleDone == null) handleDone = _defaultHandleDone;
134 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink); 150 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink);
135 } 151 }
136 )); 152 ));
137 Stream<T> bind(Stream<S> stream) { 153 Stream<T> bind(Stream<S> stream) {
138 return super.bind(stream); 154 return super.bind(stream);
139 } 155 }
140 static void _defaultHandleData(var data, EventSink sink) { 156 static void _defaultHandleData(var data, EventSink sink) {
(...skipping 18 matching lines...) Expand all
159 Function onError, void onDone(), bool cancelOnError} 175 Function onError, void onDone(), bool cancelOnError}
160 ) { 176 ) {
161 cancelOnError = identical(true, cancelOnError); 177 cancelOnError = identical(true, cancelOnError);
162 StreamSubscription<T> result = _transformer(_stream, cancelOnError); 178 StreamSubscription<T> result = _transformer(_stream, cancelOnError);
163 result.onData(onData); 179 result.onData(onData);
164 result.onError(onError); 180 result.onError(onError);
165 result.onDone(onDone); 181 result.onDone(onDone);
166 return result; 182 return result;
167 } 183 }
168 } 184 }
169 typedef EventSink<S> __t121<T, S>(EventSink<T> __u122); 185 typedef EventSink<dynamic> __t160(EventSink<dynamic> __u161);
170 typedef dynamic __t123<T>(EventSink<T> __u124); 186 typedef EventSink<S> __t162<T, S>(EventSink<T> __u163);
187 typedef void __t165(dynamic __u166);
188 typedef void __t167<T>(T __u168);
189 typedef EventSink<S> __t171<T, S>(EventSink<T> __u172);
190 typedef dynamic __t173<T>(EventSink<T> __u174);
OLDNEW
« no previous file with comments | « test/dart_codegen/expect/async/stream_pipe.dart ('k') | test/dart_codegen/expect/async/timer.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698