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

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

Issue 1096583002: Reifier hookup (Closed) Base URL: git@github.com:dart-lang/dart-dev-compiler.git@master
Patch Set: Address comments 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 99 matching lines...) Expand 10 before | Expand all | Expand 10 after
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(((__x64) => DEVC$RT.cast(__x64, DEVC$RT.type((__t62<T> _) { 120 ) : super(((__x64) => DEVC$RT.cast(__x64, DEVC$RT.type((__CastType62<T> _) {
121 } 121 }
122 ), DEVC$RT.type((_SinkMapper<S, T> _) { 122 ), DEVC$RT.type((_SinkMapper<S, T> _) {
123 } 123 }
124 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers. dart: """, __x64 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) { 124 ), "InferableClosure", """line 233, column 15 of dart:async/stream_transformers. dart: """, __x64 is _SinkMapper<S, T>, false))((EventSink<T> outputSink) {
125 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __t68, DEV C$RT.type((__t65<S, T> _) { 125 if (handleData == null) handleData = DEVC$RT.cast(_defaultHandleData, __CastType 68, DEVC$RT.type((__CastType65<S, T> _) {
126 } 126 }
127 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar t: """, _defaultHandleData is __t65<S, T>, false); 127 ), "CompositeCast", """line 234, column 48 of dart:async/stream_transformers.dar t: """, _defaultHandleData is __CastType65<S, T>, false);
128 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __t75, DEVC$RT.type((__t71<T> _) { 128 if (handleError == null) handleError = DEVC$RT.cast(_defaultHandleError, __Cast Type75, DEVC$RT.type((__CastType71<T> _) {
129 } 129 }
130 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar t: """, _defaultHandleError is __t71<T>, false); 130 ), "CompositeCast", """line 235, column 50 of dart:async/stream_transformers.dar t: """, _defaultHandleError is __CastType71<T>, false);
131 if (handleDone == null) handleDone = _defaultHandleDone; 131 if (handleDone == null) handleDone = _defaultHandleDone;
132 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink); 132 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink);
133 } 133 }
134 )); 134 ));
135 Stream<T> bind(Stream<S> stream) { 135 Stream<T> bind(Stream<S> stream) {
136 return super.bind(stream); 136 return super.bind(stream);
137 } 137 }
138 static void _defaultHandleData(var data, EventSink sink) { 138 static void _defaultHandleData(var data, EventSink sink) {
139 sink.add(data); 139 sink.add(data);
140 } 140 }
(...skipping 16 matching lines...) Expand all
157 Function onError, void onDone(), bool cancelOnError} 157 Function onError, void onDone(), bool cancelOnError}
158 ) { 158 ) {
159 cancelOnError = identical(true, cancelOnError); 159 cancelOnError = identical(true, cancelOnError);
160 StreamSubscription<T> result = _transformer(_stream, cancelOnError); 160 StreamSubscription<T> result = _transformer(_stream, cancelOnError);
161 result.onData(onData); 161 result.onData(onData);
162 result.onError(onError); 162 result.onError(onError);
163 result.onDone(onDone); 163 result.onDone(onDone);
164 return result; 164 return result;
165 } 165 }
166 } 166 }
167 typedef dynamic __t62<T>(EventSink<T> __u63); 167 typedef dynamic __CastType62<T>(EventSink<T> __u63);
168 typedef void __t65<S, T>(S __u66, EventSink<T> __u67); 168 typedef void __CastType65<S, T>(S __u66, EventSink<T> __u67);
169 typedef void __t68(dynamic __u69, EventSink<dynamic> __u70); 169 typedef void __CastType68(dynamic __u69, EventSink<dynamic> __u70);
170 typedef void __t71<T>(Object __u72, StackTrace __u73, EventSink<T> __u74); 170 typedef void __CastType71<T>(Object __u72, StackTrace __u73, EventSink<T> __u74 );
171 typedef void __t75(dynamic __u76, StackTrace __u77, EventSink<dynamic> __u78); 171 typedef void __CastType75(dynamic __u76, StackTrace __u77, EventSink<dynamic> _ _u78);
OLDNEW
« no previous file with comments | « test/dart_codegen/expect/async/stream_impl.dart ('k') | test/dart_codegen/expect/async/timer.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698