OLD | NEW |
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 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
54 void _handleData(S data) { | 54 void _handleData(S data) { |
55 try { | 55 try { |
56 _transformerSink.add(data); | 56 _transformerSink.add(data); |
57 } | 57 } |
58 catch (e, s) { | 58 catch (e, s) { |
59 _addError(e, s); | 59 _addError(e, s); |
60 } | 60 } |
61 } | 61 } |
62 void _handleError(error, [stackTrace]) { | 62 void _handleError(error, [stackTrace]) { |
63 try { | 63 try { |
64 _transformerSink.addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace,
"CastGeneral", """line 127, column 40 of dart:async/stream_transformers.dart: "
"", stackTrace is StackTrace, true)); | 64 _transformerSink.addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace,
"DynamicCast", """line 127, column 40 of dart:async/stream_transformers.dart: "
"", stackTrace is StackTrace, true)); |
65 } | 65 } |
66 catch (e, s) { | 66 catch (e, s) { |
67 if (identical(e, error)) { | 67 if (identical(e, error)) { |
68 _addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "CastGeneral"
, """line 130, column 26 of dart:async/stream_transformers.dart: """, stackTrace
is StackTrace, true)); | 68 _addError(error, DEVC$RT.cast(stackTrace, dynamic, StackTrace, "DynamicCast"
, """line 130, column 26 of dart:async/stream_transformers.dart: """, stackTrace
is StackTrace, true)); |
69 } | 69 } |
70 else { | 70 else { |
71 _addError(e, s); | 71 _addError(e, s); |
72 } | 72 } |
73 } | 73 } |
74 } | 74 } |
75 void _handleDone() { | 75 void _handleDone() { |
76 try { | 76 try { |
77 _subscription = null; | 77 _subscription = null; |
78 _transformerSink.close(); | 78 _transformerSink.close(); |
(...skipping 13 matching lines...) Expand all Loading... |
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 = ((__x105) => DEVC$RT.cast(__x105, DEVC$RT.
type((_SinkTransformerStreamSubscription<dynamic, dynamic> _) { | 98 StreamSubscription<T> subscription = ((__x105) => DEVC$RT.cast(__x105, DEVC$RT.
type((_SinkTransformerStreamSubscription<dynamic, dynamic> _) { |
99 } | 99 } |
100 ), DEVC$RT.type((StreamSubscription<T> _) { | 100 ), DEVC$RT.type((StreamSubscription<T> _) { |
101 } | 101 } |
102 ), "CastExact", """line 186, column 42 of dart:async/stream_transformers.dart: "
"", __x105 is StreamSubscription<T>, false))(new _SinkTransformerStreamSubscript
ion(_stream, DEVC$RT.wrap((EventSink<S> f(EventSink<T> __u106)) { | 102 ), "InferableAllocation", """line 186, column 42 of dart:async/stream_transforme
rs.dart: """, __x105 is StreamSubscription<T>, false))(new _SinkTransformerStrea
mSubscription(_stream, DEVC$RT.wrap((EventSink<S> f(EventSink<T> __u106)) { |
103 EventSink<S> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dy
namic> _) { | 103 EventSink<S> c(EventSink<T> x0) => f(DEVC$RT.cast(x0, DEVC$RT.type((EventSink<dy
namic> _) { |
104 } | 104 } |
105 ), DEVC$RT.type((EventSink<T> _) { | 105 ), DEVC$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, DEVC$RT.type((__t109<T, S> _) { | 110 , _sinkMapper, DEVC$RT.type((__t109<T, S> _) { |
111 } | 111 } |
112 ), __t107, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart
: """, _sinkMapper is __t107), onData, onError, onDone, cancelOnError)); | 112 ), __t107, "Wrap", """line 187, column 18 of dart:async/stream_transformers.dart
: """, _sinkMapper is __t107), onData, onError, onDone, cancelOnError)); |
(...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
189 } | 189 } |
190 } | 190 } |
191 typedef EventSink<dynamic> __t107(EventSink<dynamic> __u108); | 191 typedef EventSink<dynamic> __t107(EventSink<dynamic> __u108); |
192 typedef EventSink<S> __t109<T, S>(EventSink<T> __u110); | 192 typedef EventSink<S> __t109<T, S>(EventSink<T> __u110); |
193 typedef EventSink<S> __t113<T, S>(EventSink<T> __u114); | 193 typedef EventSink<S> __t113<T, S>(EventSink<T> __u114); |
194 typedef dynamic __t115<T>(EventSink<T> __u116); | 194 typedef dynamic __t115<T>(EventSink<T> __u116); |
195 typedef void __t120<S, T>(S __u121, EventSink<T> __u122); | 195 typedef void __t120<S, T>(S __u121, EventSink<T> __u122); |
196 typedef void __t123(dynamic __u124, EventSink<dynamic> __u125); | 196 typedef void __t123(dynamic __u124, EventSink<dynamic> __u125); |
197 typedef void __t129<T>(Object __u130, StackTrace __u131, EventSink<T> __u132); | 197 typedef void __t129<T>(Object __u130, StackTrace __u131, EventSink<T> __u132); |
198 typedef void __t133(dynamic __u134, StackTrace __u135, EventSink<dynamic> __u13
6); | 198 typedef void __t133(dynamic __u134, StackTrace __u135, EventSink<dynamic> __u13
6); |
OLD | NEW |