| 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.utf; | 5 part of dart.utf; |
| 6 | 6 |
| 7 class _HelperStreamController<T> extends StreamController<T> { | 7 class _HelperStreamController<T> extends StreamController<T> { |
| 8 final Function onPauseChanged; | 8 final Function onPauseChanged; |
| 9 | 9 |
| 10 _HelperStreamController(this.onPauseChanged); | 10 _HelperStreamController(this.onPauseChanged); |
| 11 | 11 |
| 12 void onPauseStateChange() { | 12 void onPauseStateChange() { |
| 13 onPauseChanged(); | 13 onPauseChanged(); |
| 14 } | 14 } |
| 15 } | 15 } |
| 16 | 16 |
| 17 abstract class _StringDecoder | 17 abstract class _StringDecoder |
| 18 extends StreamEventTransformer<List<int>, String> { | 18 extends StreamEventTransformer<List<int>, String> { |
| 19 List<int> _carry; | 19 List<int> _carry; |
| 20 List<int> _buffer; | 20 List<int> _buffer; |
| 21 int _replacementChar; | 21 int _replacementChar; |
| 22 | 22 |
| 23 _StringDecoder(int this._replacementChar); | 23 _StringDecoder(int this._replacementChar); |
| 24 | 24 |
| 25 void handleData(List<int> bytes, StreamSink<String> sink) { | 25 void handleData(List<int> bytes, EventSink<String> sink) { |
| 26 _buffer = <int>[]; | 26 _buffer = <int>[]; |
| 27 List<int> carry = _carry; | 27 List<int> carry = _carry; |
| 28 _carry = null; | 28 _carry = null; |
| 29 int pos = 0; | 29 int pos = 0; |
| 30 int available = bytes.length; | 30 int available = bytes.length; |
| 31 // If we have carry-over data, start from negative index, indicating carry | 31 // If we have carry-over data, start from negative index, indicating carry |
| 32 // index. | 32 // index. |
| 33 int goodChars = 0; | 33 int goodChars = 0; |
| 34 if (carry != null) pos = -carry.length; | 34 if (carry != null) pos = -carry.length; |
| 35 while (pos < available) { | 35 while (pos < available) { |
| (...skipping 26 matching lines...) Expand all Loading... |
| 62 goodChars = _buffer.length; | 62 goodChars = _buffer.length; |
| 63 } | 63 } |
| 64 } | 64 } |
| 65 if (_buffer.length > 0) { | 65 if (_buffer.length > 0) { |
| 66 // Limit to 'goodChars', if lower than actual charCodes in the buffer. | 66 // Limit to 'goodChars', if lower than actual charCodes in the buffer. |
| 67 sink.add(new String.fromCharCodes(_buffer)); | 67 sink.add(new String.fromCharCodes(_buffer)); |
| 68 } | 68 } |
| 69 _buffer = null; | 69 _buffer = null; |
| 70 } | 70 } |
| 71 | 71 |
| 72 void handleDone(StreamSink<String> sink) { | 72 void handleDone(EventSink<String> sink) { |
| 73 if (_carry != null) { | 73 if (_carry != null) { |
| 74 sink.add(new String.fromCharCodes( | 74 sink.add(new String.fromCharCodes( |
| 75 new List.filled(_carry.length, _replacementChar))); | 75 new List.filled(_carry.length, _replacementChar))); |
| 76 } | 76 } |
| 77 sink.close(); | 77 sink.close(); |
| 78 } | 78 } |
| 79 | 79 |
| 80 int _processBytes(int getNext()); | 80 int _processBytes(int getNext()); |
| 81 | 81 |
| 82 void _addChar(int char) { | 82 void _addChar(int char) { |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 135 } | 135 } |
| 136 _addChar(value); | 136 _addChar(value); |
| 137 return 1; | 137 return 1; |
| 138 } | 138 } |
| 139 } | 139 } |
| 140 | 140 |
| 141 | 141 |
| 142 abstract class _StringEncoder | 142 abstract class _StringEncoder |
| 143 extends StreamEventTransformer<String, List<int>> { | 143 extends StreamEventTransformer<String, List<int>> { |
| 144 | 144 |
| 145 void handleData(String data, StreamSink<List<int>> sink) { | 145 void handleData(String data, EventSink<List<int>> sink) { |
| 146 sink.add(_processString(data)); | 146 sink.add(_processString(data)); |
| 147 } | 147 } |
| 148 | 148 |
| 149 List<int> _processString(String string); | 149 List<int> _processString(String string); |
| 150 } | 150 } |
| 151 | 151 |
| 152 /** | 152 /** |
| 153 * StringTransformer that UTF-8 encodes a stream of strings. | 153 * StringTransformer that UTF-8 encodes a stream of strings. |
| 154 */ | 154 */ |
| 155 class Utf8EncoderTransformer extends _StringEncoder { | 155 class Utf8EncoderTransformer extends _StringEncoder { |
| (...skipping 23 matching lines...) Expand all Loading... |
| 179 } | 179 } |
| 180 for (int i = additionalBytes; i > 0; i--) { | 180 for (int i = additionalBytes; i > 0; i--) { |
| 181 // 10xxxxxx (xxxxxx is next 6 bits from the top). | 181 // 10xxxxxx (xxxxxx is next 6 bits from the top). |
| 182 bytes.add(((charCode >> (6 * (i - 1))) & 0x3F) | 0x80); | 182 bytes.add(((charCode >> (6 * (i - 1))) & 0x3F) | 0x80); |
| 183 } | 183 } |
| 184 pos += additionalBytes + 1; | 184 pos += additionalBytes + 1; |
| 185 } | 185 } |
| 186 return bytes; | 186 return bytes; |
| 187 } | 187 } |
| 188 } | 188 } |
| OLD | NEW |