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

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: 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 = ((__x123) => DDC$RT.cast(__x123, 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: " "", __x123 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript ion(_stream, _sinkMapper, onData, onError, onDone, cancelOnError));
103 return subscription; 103 return subscription;
104 } 104 }
105 } 105 }
106 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); 106 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink);
107 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve ntSink<T> sink); 107 typedef void _TransformErrorHandler<T>(Object error, StackTrace stackTrace, Eve ntSink<T> sink);
108 typedef void _TransformDoneHandler<T>(EventSink<T> sink); 108 typedef void _TransformDoneHandler<T>(EventSink<T> sink);
109 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand ler<S, T> _handleData; 109 class _HandlerEventSink<S, T> implements EventSink<S> {final _TransformDataHand ler<S, T> _handleData;
110 final _TransformErrorHandler<T> _handleError; 110 final _TransformErrorHandler<T> _handleError;
111 final _TransformDoneHandler<T> _handleDone; 111 final _TransformDoneHandler<T> _handleDone;
112 final EventSink<T> _sink; 112 final EventSink<T> _sink;
113 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink); 113 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink);
114 void add(S data) => _handleData(data, _sink); 114 void add(S data) => _handleData(data, _sink);
115 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink); 115 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink);
116 void close() => _handleDone(_sink); 116 void close() => _handleDone(_sink);
117 } 117 }
118 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({ 118 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)} 119 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)) { 120 ) : super(((__x130) => DDC$RT.wrap((dynamic f(EventSink<T> __u125)) {
121 dynamic c(EventSink<T> x0) => ((__x119) => DDC$RT.cast(__x119, dynamic, DDC$RT.t ype((EventSink<S> _) { 121 dynamic c(EventSink<T> x0) => ((__x124) => DDC$RT.cast(__x124, dynamic, DDC$RT.t ype((EventSink<S> _) {
122 } 122 }
123 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x119 is EventSink<S>, false))(f(x0)); 123 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x124 is EventSink<S>, false))(f(x0));
124 return f == null ? null : c; 124 return f == null ? null : c;
125 } 125 }
126 , __x125, DDC$RT.type((__t123<T> _) { 126 , __x130, DDC$RT.type((__t128<T> _) {
127 } 127 }
128 ), DDC$RT.type((__t121<T, S> _) { 128 ), DDC$RT.type((__t126<T, S> _) {
129 } 129 }
130 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x125 is __t121<T, S>))((EventSink<T> outputSink) { 130 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x130 is __t126<T, S>))((EventSink<T> outputSink) {
131 if (handleData == null) handleData = _defaultHandleData; 131 if (handleData == null) handleData = _defaultHandleData;
132 if (handleError == null) handleError = _defaultHandleError; 132 if (handleError == null) handleError = _defaultHandleError;
133 if (handleDone == null) handleDone = _defaultHandleDone; 133 if (handleDone == null) handleDone = _defaultHandleDone;
134 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink); 134 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink);
135 } 135 }
136 )); 136 ));
137 Stream<T> bind(Stream<S> stream) { 137 Stream<T> bind(Stream<S> stream) {
138 return super.bind(stream); 138 return super.bind(stream);
139 } 139 }
140 static void _defaultHandleData(var data, EventSink sink) { 140 static void _defaultHandleData(var data, EventSink sink) {
(...skipping 18 matching lines...) Expand all
159 Function onError, void onDone(), bool cancelOnError} 159 Function onError, void onDone(), bool cancelOnError}
160 ) { 160 ) {
161 cancelOnError = identical(true, cancelOnError); 161 cancelOnError = identical(true, cancelOnError);
162 StreamSubscription<T> result = _transformer(_stream, cancelOnError); 162 StreamSubscription<T> result = _transformer(_stream, cancelOnError);
163 result.onData(onData); 163 result.onData(onData);
164 result.onError(onError); 164 result.onError(onError);
165 result.onDone(onDone); 165 result.onDone(onDone);
166 return result; 166 return result;
167 } 167 }
168 } 168 }
169 typedef EventSink<S> __t121<T, S>(EventSink<T> __u122); 169 typedef EventSink<S> __t126<T, S>(EventSink<T> __u127);
170 typedef dynamic __t123<T>(EventSink<T> __u124); 170 typedef dynamic __t128<T>(EventSink<T> __u129);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698