OLD | NEW |
1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 part of dart.convert; | 5 part of dart.convert; |
6 | 6 |
7 typedef void _ChunkedConversionCallback<T>(T accumulated); | 7 typedef void _ChunkedConversionCallback<T>(T accumulated); |
8 | 8 |
9 /// This class is deprecated. Extend [Converter] directly. | 9 /// This class is deprecated. Extend [Converter] directly. |
10 @deprecated | 10 @deprecated |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
77 /** The output sink for the converter. */ | 77 /** The output sink for the converter. */ |
78 final EventSink<T> _eventSink; | 78 final EventSink<T> _eventSink; |
79 | 79 |
80 /** | 80 /** |
81 * The input sink for new data. All data that is received with | 81 * The input sink for new data. All data that is received with |
82 * [handleData] is added into this sink. | 82 * [handleData] is added into this sink. |
83 */ | 83 */ |
84 final Sink<S> _chunkedSink; | 84 final Sink<S> _chunkedSink; |
85 | 85 |
86 _ConverterStreamEventSink( | 86 _ConverterStreamEventSink( |
87 Converter/*=Converter<S, T>*/ converter, | 87 Converter<S, T> converter, |
88 EventSink<T> sink) | 88 EventSink<T> sink) |
89 : this._eventSink = sink, | 89 : this._eventSink = sink, |
90 _chunkedSink = converter.startChunkedConversion(sink); | 90 _chunkedSink = converter.startChunkedConversion(sink); |
91 | 91 |
92 void add(S o) { _chunkedSink.add(o); } | 92 void add(S o) { _chunkedSink.add(o); } |
93 void addError(Object error, [StackTrace stackTrace]) { | 93 void addError(Object error, [StackTrace stackTrace]) { |
94 _eventSink.addError(error, stackTrace); | 94 _eventSink.addError(error, stackTrace); |
95 } | 95 } |
96 void close() { _chunkedSink.close(); } | 96 void close() { _chunkedSink.close(); } |
97 } | 97 } |
OLD | NEW |