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

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

Issue 977613002: Make int and double nullable by default (Closed) Base URL: https://github.com/dart-lang/dev_compiler.git@master
Patch Set: actually upload changes 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 = ((__x158) => DDC$RT.cast(__x158, DDC$RT.ty pe((_SinkTransformerStreamSubscription<dynamic, dynamic> _) { 98 StreamSubscription<T> subscription = ((__x144) => DDC$RT.cast(__x144, 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: " "", __x158 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript ion(_stream, DDC$RT.wrap((EventSink<S> f(EventSink<T> __u159)) { 102 ), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: " "", __x144 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript ion(_stream, DDC$RT.wrap((EventSink<S> f(EventSink<T> __u145)) {
103 EventSink<S> c(EventSink<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((EventSink<dyna mic> _) { 103 EventSink<S> c(EventSink<T> x0) => f(DDC$RT.cast(x0, DDC$RT.type((EventSink<dyna mic> _) {
104 } 104 }
105 ), DDC$RT.type((EventSink<T> _) { 105 ), DDC$RT.type((EventSink<T> _) {
106 } 106 }
107 ), "CastParam", """line 187, column 18 of dart:async/stream_transformers.dart: " "", x0 is EventSink<T>, false)); 107 ), "CastParam", """line 187, column 18 of dart:async/stream_transformers.dart: " "", x0 is EventSink<T>, false));
108 return f == null ? null : c; 108 return f == null ? null : c;
109 } 109 }
110 , _sinkMapper, DDC$RT.type((__t162<T, S> _) { 110 , _sinkMapper, DDC$RT.type((__t148<T, S> _) {
111 } 111 }
112 ), __t160, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart : """, _sinkMapper is __t160), DDC$RT.wrap((void f(T __u164)) { 112 ), __t146, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart : """, _sinkMapper is __t146), DDC$RT.wrap((void f(T __u150)) {
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)); 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; 114 return f == null ? null : c;
115 } 115 }
116 , onData, DDC$RT.type((__t167<T> _) { 116 , onData, DDC$RT.type((__t153<T> _) {
117 } 117 }
118 ), __t165, "Wrap", """line 187, column 31 of dart:async/stream_transformers.dart : """, onData is __t165), onError, onDone, cancelOnError)); 118 ), __t151, "Wrap", """line 187, column 31 of dart:async/stream_transformers.dart : """, onData is __t151), onError, onDone, cancelOnError));
119 return subscription; 119 return subscription;
120 } 120 }
121 } 121 }
122 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink); 122 typedef void _TransformDataHandler<S, T>(S data, EventSink<T> sink);
123 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);
124 typedef void _TransformDoneHandler<T>(EventSink<T> sink); 124 typedef void _TransformDoneHandler<T>(EventSink<T> sink);
125 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;
126 final _TransformErrorHandler<T> _handleError; 126 final _TransformErrorHandler<T> _handleError;
127 final _TransformDoneHandler<T> _handleDone; 127 final _TransformDoneHandler<T> _handleDone;
128 final EventSink<T> _sink; 128 final EventSink<T> _sink;
129 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink); 129 _HandlerEventSink(this._handleData, this._handleError, this._handleDone, this._ sink);
130 void add(S data) => _handleData(data, _sink); 130 void add(S data) => _handleData(data, _sink);
131 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink); 131 void addError(Object error, [StackTrace stackTrace]) => _handleError(error, sta ckTrace, _sink);
132 void close() => _handleDone(_sink); 132 void close() => _handleDone(_sink);
133 } 133 }
134 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({ 134 class _StreamHandlerTransformer<S, T> extends _StreamSinkTransformer<S, T> {_St reamHandlerTransformer({
135 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)}
136 ) : super(((__x175) => DDC$RT.wrap((dynamic f(EventSink<T> __u170)) { 136 ) : super(((__x161) => DDC$RT.wrap((dynamic f(EventSink<T> __u156)) {
137 dynamic c(EventSink<T> x0) => ((__x169) => DDC$RT.cast(__x169, dynamic, DDC$RT.t ype((EventSink<S> _) { 137 dynamic c(EventSink<T> x0) => ((__x155) => DDC$RT.cast(__x155, dynamic, DDC$RT.t ype((EventSink<S> _) {
138 } 138 }
139 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x169 is EventSink<S>, false))(f(x0)); 139 ), "CastResult", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x155 is EventSink<S>, false))(f(x0));
140 return f == null ? null : c; 140 return f == null ? null : c;
141 } 141 }
142 , __x175, DDC$RT.type((__t173<T> _) { 142 , __x161, DDC$RT.type((__t159<T> _) {
143 } 143 }
144 ), DDC$RT.type((__t171<T, S> _) { 144 ), DDC$RT.type((__t157<T, S> _) {
145 } 145 }
146 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x175 is __t171<T, S>))((EventSink<T> outputSink) { 146 ), "WrapLiteral", """line 233, column 15 of dart:async/stream_transformers.dart: """, __x161 is __t157<T, S>))((EventSink<T> outputSink) {
147 if (handleData == null) handleData = _defaultHandleData; 147 if (handleData == null) handleData = _defaultHandleData;
148 if (handleError == null) handleError = _defaultHandleError; 148 if (handleError == null) handleError = _defaultHandleError;
149 if (handleDone == null) handleDone = _defaultHandleDone; 149 if (handleDone == null) handleDone = _defaultHandleDone;
150 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink); 150 return new _HandlerEventSink<S, T>(handleData, handleError, handleDone, outputS ink);
151 } 151 }
152 )); 152 ));
153 Stream<T> bind(Stream<S> stream) { 153 Stream<T> bind(Stream<S> stream) {
154 return super.bind(stream); 154 return super.bind(stream);
155 } 155 }
156 static void _defaultHandleData(var data, EventSink sink) { 156 static void _defaultHandleData(var data, EventSink sink) {
(...skipping 18 matching lines...) Expand all
175 Function onError, void onDone(), bool cancelOnError} 175 Function onError, void onDone(), bool cancelOnError}
176 ) { 176 ) {
177 cancelOnError = identical(true, cancelOnError); 177 cancelOnError = identical(true, cancelOnError);
178 StreamSubscription<T> result = _transformer(_stream, cancelOnError); 178 StreamSubscription<T> result = _transformer(_stream, cancelOnError);
179 result.onData(onData); 179 result.onData(onData);
180 result.onError(onError); 180 result.onError(onError);
181 result.onDone(onDone); 181 result.onDone(onDone);
182 return result; 182 return result;
183 } 183 }
184 } 184 }
185 typedef EventSink<dynamic> __t160(EventSink<dynamic> __u161); 185 typedef EventSink<dynamic> __t146(EventSink<dynamic> __u147);
186 typedef EventSink<S> __t162<T, S>(EventSink<T> __u163); 186 typedef EventSink<S> __t148<T, S>(EventSink<T> __u149);
187 typedef void __t165(dynamic __u166); 187 typedef void __t151(dynamic __u152);
188 typedef void __t167<T>(T __u168); 188 typedef void __t153<T>(T __u154);
189 typedef EventSink<S> __t171<T, S>(EventSink<T> __u172); 189 typedef EventSink<S> __t157<T, S>(EventSink<T> __u158);
190 typedef dynamic __t173<T>(EventSink<T> __u174); 190 typedef dynamic __t159<T>(EventSink<T> __u160);
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698