| OLD | NEW |
| 1 var convert; | 1 var convert; |
| 2 (function(exports) { | 2 (function(exports) { |
| 3 'use strict'; | 3 'use strict'; |
| 4 let ASCII = dart.const(new AsciiCodec()); | 4 let ASCII = dart.const(new AsciiCodec()); |
| 5 let _ASCII_MASK = 127; | 5 let _ASCII_MASK = 127; |
| 6 let _allowInvalid = Symbol('_allowInvalid'); | 6 let _allowInvalid = Symbol('_allowInvalid'); |
| 7 let Codec$ = dart.generic(function(S, T) { | 7 let Codec$ = dart.generic(function(S, T) { |
| 8 class Codec extends core.Object { | 8 class Codec extends core.Object { |
| 9 Codec() { | 9 Codec() { |
| 10 } | 10 } |
| (...skipping 14 matching lines...) Expand all Loading... |
| 25 } | 25 } |
| 26 } | 26 } |
| 27 return Codec; | 27 return Codec; |
| 28 }); | 28 }); |
| 29 let Codec = Codec$(); | 29 let Codec = Codec$(); |
| 30 class Encoding extends Codec$(core.String, core.List$(core.int)) { | 30 class Encoding extends Codec$(core.String, core.List$(core.int)) { |
| 31 Encoding() { | 31 Encoding() { |
| 32 super.Codec(); | 32 super.Codec(); |
| 33 } | 33 } |
| 34 decodeStream(byteStream) { | 34 decodeStream(byteStream) { |
| 35 return dart.as(byteStream.transform(dart.as(this.decoder, async.StreamTran
sformer$(core.List$(core.int), dart.dynamic))).fold(new core.StringBuffer(), (bu
ffer, string) => ((() => { | 35 return dart.as(byteStream.transform(this.decoder).fold(new core.StringBuff
er(), (buffer, string) => ((() => { |
| 36 dart.dsend(buffer, 'write', string); | 36 dart.dsend(buffer, 'write', string); |
| 37 return buffer; | 37 return buffer; |
| 38 })())).then(buffer => dart.toString(buffer)), async.Future$(core.String)); | 38 })())).then(buffer => dart.toString(buffer)), async.Future$(core.String)); |
| 39 } | 39 } |
| 40 static getByName(name) { | 40 static getByName(name) { |
| 41 if (name == null) | 41 if (name == null) |
| 42 return null; | 42 return null; |
| 43 name = name.toLowerCase(); | 43 name = name.toLowerCase(); |
| 44 return Encoding._nameToEncoding.get(name); | 44 return Encoding._nameToEncoding.get(name); |
| 45 } | 45 } |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 79 let _subsetMask = Symbol('_subsetMask'); | 79 let _subsetMask = Symbol('_subsetMask'); |
| 80 let Converter$ = dart.generic(function(S, T) { | 80 let Converter$ = dart.generic(function(S, T) { |
| 81 class Converter extends core.Object { | 81 class Converter extends core.Object { |
| 82 Converter() { | 82 Converter() { |
| 83 } | 83 } |
| 84 fuse(other) { | 84 fuse(other) { |
| 85 dart.as(other, Converter$(T, dart.dynamic)); | 85 dart.as(other, Converter$(T, dart.dynamic)); |
| 86 return new (_FusedConverter$(S, T, dart.dynamic))(this, other); | 86 return new (_FusedConverter$(S, T, dart.dynamic))(this, other); |
| 87 } | 87 } |
| 88 startChunkedConversion(sink) { | 88 startChunkedConversion(sink) { |
| 89 dart.as(sink, core.Sink$(T)); |
| 89 throw new core.UnsupportedError(`This converter does not support chunked
conversions: ${this}`); | 90 throw new core.UnsupportedError(`This converter does not support chunked
conversions: ${this}`); |
| 90 } | 91 } |
| 91 bind(source) { | 92 bind(source) { |
| 92 return new async.Stream.eventTransformed(source, (sink => new _Converter
StreamEventSink(this, sink)).bind(this)); | 93 dart.as(source, async.Stream$(S)); |
| 94 return new async.Stream$(T).eventTransformed(source, (sink => new _Conve
rterStreamEventSink(this, sink)).bind(this)); |
| 93 } | 95 } |
| 94 } | 96 } |
| 95 Converter[dart.implements] = () => [async.StreamTransformer]; | 97 Converter[dart.implements] = () => [async.StreamTransformer$(S, T)]; |
| 96 return Converter; | 98 return Converter; |
| 97 }); | 99 }); |
| 98 let Converter = Converter$(); | 100 let Converter = Converter$(); |
| 99 class _UnicodeSubsetEncoder extends Converter$(core.String, core.List$(core.in
t)) { | 101 class _UnicodeSubsetEncoder extends Converter$(core.String, core.List$(core.in
t)) { |
| 100 _UnicodeSubsetEncoder(subsetMask) { | 102 _UnicodeSubsetEncoder(subsetMask) { |
| 101 this[_subsetMask] = subsetMask; | 103 this[_subsetMask] = subsetMask; |
| 102 super.Converter(); | 104 super.Converter(); |
| 103 } | 105 } |
| 104 convert(string, start, end) { | 106 convert(string, start, end) { |
| 105 if (start === void 0) | 107 if (start === void 0) |
| (...skipping 15 matching lines...) Expand all Loading... |
| 121 } | 123 } |
| 122 return dart.as(result, core.List$(core.int)); | 124 return dart.as(result, core.List$(core.int)); |
| 123 } | 125 } |
| 124 startChunkedConversion(sink) { | 126 startChunkedConversion(sink) { |
| 125 if (!dart.is(sink, ByteConversionSink)) { | 127 if (!dart.is(sink, ByteConversionSink)) { |
| 126 sink = new ByteConversionSink.from(sink); | 128 sink = new ByteConversionSink.from(sink); |
| 127 } | 129 } |
| 128 return new _UnicodeSubsetEncoderSink(this[_subsetMask], dart.as(sink, Byte
ConversionSink)); | 130 return new _UnicodeSubsetEncoderSink(this[_subsetMask], dart.as(sink, Byte
ConversionSink)); |
| 129 } | 131 } |
| 130 bind(stream) { | 132 bind(stream) { |
| 131 return dart.as(super.bind(stream), async.Stream$(core.List$(core.int))); | 133 return super.bind(stream); |
| 132 } | 134 } |
| 133 } | 135 } |
| 134 class AsciiEncoder extends _UnicodeSubsetEncoder { | 136 class AsciiEncoder extends _UnicodeSubsetEncoder { |
| 135 AsciiEncoder() { | 137 AsciiEncoder() { |
| 136 super._UnicodeSubsetEncoder(_ASCII_MASK); | 138 super._UnicodeSubsetEncoder(_ASCII_MASK); |
| 137 } | 139 } |
| 138 } | 140 } |
| 139 let _sink = Symbol('_sink'); | 141 let _sink = Symbol('_sink'); |
| 140 class StringConversionSinkMixin extends core.Object { | 142 class StringConversionSinkMixin extends core.Object { |
| 141 add(str) { | 143 add(str) { |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 204 let buffer = new core.StringBuffer(); | 206 let buffer = new core.StringBuffer(); |
| 205 for (let i = start; dart.notNull(i) < dart.notNull(end); i = dart.notNull(
i) + 1) { | 207 for (let i = start; dart.notNull(i) < dart.notNull(end); i = dart.notNull(
i) + 1) { |
| 206 let value = bytes[core.$get](i); | 208 let value = bytes[core.$get](i); |
| 207 if ((dart.notNull(value) & ~dart.notNull(this[_subsetMask])) != 0) | 209 if ((dart.notNull(value) & ~dart.notNull(this[_subsetMask])) != 0) |
| 208 value = 65533; | 210 value = 65533; |
| 209 buffer.writeCharCode(value); | 211 buffer.writeCharCode(value); |
| 210 } | 212 } |
| 211 return dart.toString(buffer); | 213 return dart.toString(buffer); |
| 212 } | 214 } |
| 213 bind(stream) { | 215 bind(stream) { |
| 214 return dart.as(super.bind(stream), async.Stream$(core.String)); | 216 return super.bind(stream); |
| 215 } | 217 } |
| 216 } | 218 } |
| 217 class AsciiDecoder extends _UnicodeSubsetDecoder { | 219 class AsciiDecoder extends _UnicodeSubsetDecoder { |
| 218 AsciiDecoder(opts) { | 220 AsciiDecoder(opts) { |
| 219 let allowInvalid = opts && 'allowInvalid' in opts ? opts.allowInvalid : fa
lse; | 221 let allowInvalid = opts && 'allowInvalid' in opts ? opts.allowInvalid : fa
lse; |
| 220 super._UnicodeSubsetDecoder(allowInvalid, _ASCII_MASK); | 222 super._UnicodeSubsetDecoder(allowInvalid, _ASCII_MASK); |
| 221 } | 223 } |
| 222 startChunkedConversion(sink) { | 224 startChunkedConversion(sink) { |
| 223 let stringSink = null; | 225 let stringSink = null; |
| 224 if (dart.is(sink, StringConversionSink)) { | 226 if (dart.is(sink, StringConversionSink)) { |
| (...skipping 255 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 480 _FusedConverter(first, second) { | 482 _FusedConverter(first, second) { |
| 481 this[_first] = first; | 483 this[_first] = first; |
| 482 this[_second] = second; | 484 this[_second] = second; |
| 483 super.Converter(); | 485 super.Converter(); |
| 484 } | 486 } |
| 485 convert(input) { | 487 convert(input) { |
| 486 dart.as(input, S); | 488 dart.as(input, S); |
| 487 return dart.as(this[_second].convert(this[_first].convert(input)), T); | 489 return dart.as(this[_second].convert(this[_first].convert(input)), T); |
| 488 } | 490 } |
| 489 startChunkedConversion(sink) { | 491 startChunkedConversion(sink) { |
| 492 dart.as(sink, core.Sink$(T)); |
| 490 return this[_first].startChunkedConversion(this[_second].startChunkedCon
version(sink)); | 493 return this[_first].startChunkedConversion(this[_second].startChunkedCon
version(sink)); |
| 491 } | 494 } |
| 492 } | 495 } |
| 493 return _FusedConverter; | 496 return _FusedConverter; |
| 494 }); | 497 }); |
| 495 let _FusedConverter = _FusedConverter$(); | 498 let _FusedConverter = _FusedConverter$(); |
| 496 let HTML_ESCAPE = dart.const(new HtmlEscape()); | 499 let HTML_ESCAPE = dart.const(new HtmlEscape()); |
| 497 let _name = Symbol('_name'); | 500 let _name = Symbol('_name'); |
| 498 class HtmlEscapeMode extends core.Object { | 501 class HtmlEscapeMode extends core.Object { |
| 499 _(name, escapeLtGt, escapeQuot, escapeApos, escapeSlash) { | 502 _(name, escapeLtGt, escapeQuot, escapeApos, escapeSlash) { |
| (...skipping 194 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 694 } | 697 } |
| 695 startChunkedConversion(sink) { | 698 startChunkedConversion(sink) { |
| 696 if (!dart.is(sink, StringConversionSink)) { | 699 if (!dart.is(sink, StringConversionSink)) { |
| 697 sink = new StringConversionSink.from(sink); | 700 sink = new StringConversionSink.from(sink); |
| 698 } else if (dart.is(sink, _Utf8EncoderSink)) { | 701 } else if (dart.is(sink, _Utf8EncoderSink)) { |
| 699 return new _JsonUtf8EncoderSink(sink[_sink], this[_toEncodable$], JsonUt
f8Encoder._utf8Encode(this.indent), JsonUtf8Encoder.DEFAULT_BUFFER_SIZE); | 702 return new _JsonUtf8EncoderSink(sink[_sink], this[_toEncodable$], JsonUt
f8Encoder._utf8Encode(this.indent), JsonUtf8Encoder.DEFAULT_BUFFER_SIZE); |
| 700 } | 703 } |
| 701 return new _JsonEncoderSink(dart.as(sink, StringConversionSink), this[_toE
ncodable$], this.indent); | 704 return new _JsonEncoderSink(dart.as(sink, StringConversionSink), this[_toE
ncodable$], this.indent); |
| 702 } | 705 } |
| 703 bind(stream) { | 706 bind(stream) { |
| 704 return dart.as(super.bind(stream), async.Stream$(core.String)); | 707 return super.bind(stream); |
| 705 } | 708 } |
| 706 fuse(other) { | 709 fuse(other) { |
| 707 if (dart.is(other, Utf8Encoder)) { | 710 if (dart.is(other, Utf8Encoder)) { |
| 708 return new JsonUtf8Encoder(this.indent, dart.as(this[_toEncodable$], __C
astType4)); | 711 return new JsonUtf8Encoder(this.indent, dart.as(this[_toEncodable$], __C
astType4)); |
| 709 } | 712 } |
| 710 return super.fuse(other); | 713 return super.fuse(other); |
| 711 } | 714 } |
| 712 } | 715 } |
| 713 dart.defineNamedConstructor(JsonEncoder, 'withIndent'); | 716 dart.defineNamedConstructor(JsonEncoder, 'withIndent'); |
| 714 let _indent = Symbol('_indent'); | 717 let _indent = Symbol('_indent'); |
| (...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 769 startChunkedConversion(sink) { | 772 startChunkedConversion(sink) { |
| 770 let byteSink = null; | 773 let byteSink = null; |
| 771 if (dart.is(sink, ByteConversionSink)) { | 774 if (dart.is(sink, ByteConversionSink)) { |
| 772 byteSink = sink; | 775 byteSink = sink; |
| 773 } else { | 776 } else { |
| 774 byteSink = new ByteConversionSink.from(sink); | 777 byteSink = new ByteConversionSink.from(sink); |
| 775 } | 778 } |
| 776 return new _JsonUtf8EncoderSink(byteSink, this[_toEncodable$], this[_inden
t], this[_bufferSize]); | 779 return new _JsonUtf8EncoderSink(byteSink, this[_toEncodable$], this[_inden
t], this[_bufferSize]); |
| 777 } | 780 } |
| 778 bind(stream) { | 781 bind(stream) { |
| 779 return dart.as(super.bind(stream), async.Stream$(core.List$(core.int))); | 782 return super.bind(stream); |
| 780 } | 783 } |
| 781 fuse(other) { | 784 fuse(other) { |
| 782 return super.fuse(other); | 785 return super.fuse(other); |
| 783 } | 786 } |
| 784 } | 787 } |
| 785 JsonUtf8Encoder.DEFAULT_BUFFER_SIZE = 256; | 788 JsonUtf8Encoder.DEFAULT_BUFFER_SIZE = 256; |
| 786 let _isDone = Symbol('_isDone'); | 789 let _isDone = Symbol('_isDone'); |
| 787 class _JsonEncoderSink extends ChunkedConversionSink$(core.Object) { | 790 class _JsonEncoderSink extends ChunkedConversionSink$(core.Object) { |
| 788 _JsonEncoderSink(sink, toEncodable, indent) { | 791 _JsonEncoderSink(sink, toEncodable, indent) { |
| 789 this[_sink] = sink; | 792 this[_sink] = sink; |
| (...skipping 585 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1375 LineSplitter() { | 1378 LineSplitter() { |
| 1376 super.Converter(); | 1379 super.Converter(); |
| 1377 } | 1380 } |
| 1378 convert(data) { | 1381 convert(data) { |
| 1379 let lines = new (core.List$(core.String))(); | 1382 let lines = new (core.List$(core.String))(); |
| 1380 _LineSplitterSink._addSlice(data, 0, data.length, true, lines[core.$add].b
ind(lines)); | 1383 _LineSplitterSink._addSlice(data, 0, data.length, true, lines[core.$add].b
ind(lines)); |
| 1381 return lines; | 1384 return lines; |
| 1382 } | 1385 } |
| 1383 startChunkedConversion(sink) { | 1386 startChunkedConversion(sink) { |
| 1384 if (!dart.is(sink, StringConversionSink)) { | 1387 if (!dart.is(sink, StringConversionSink)) { |
| 1385 sink = new StringConversionSink.from(sink); | 1388 sink = new StringConversionSink.from(dart.as(sink, core.Sink$(core.Strin
g))); |
| 1386 } | 1389 } |
| 1387 return new _LineSplitterSink(dart.as(sink, StringConversionSink)); | 1390 return new _LineSplitterSink(dart.as(sink, StringConversionSink)); |
| 1388 } | 1391 } |
| 1389 } | 1392 } |
| 1390 let _carry = Symbol('_carry'); | 1393 let _carry = Symbol('_carry'); |
| 1391 class _LineSplitterSink extends StringConversionSinkBase { | 1394 class _LineSplitterSink extends StringConversionSinkBase { |
| 1392 _LineSplitterSink(sink) { | 1395 _LineSplitterSink(sink) { |
| 1393 this[_sink] = sink; | 1396 this[_sink] = sink; |
| 1394 this[_carry] = null; | 1397 this[_carry] = null; |
| 1395 } | 1398 } |
| (...skipping 329 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1725 } | 1728 } |
| 1726 return encoder[_buffer][core.$sublist](0, encoder[_bufferIndex]); | 1729 return encoder[_buffer][core.$sublist](0, encoder[_bufferIndex]); |
| 1727 } | 1730 } |
| 1728 startChunkedConversion(sink) { | 1731 startChunkedConversion(sink) { |
| 1729 if (!dart.is(sink, ByteConversionSink)) { | 1732 if (!dart.is(sink, ByteConversionSink)) { |
| 1730 sink = new ByteConversionSink.from(sink); | 1733 sink = new ByteConversionSink.from(sink); |
| 1731 } | 1734 } |
| 1732 return new _Utf8EncoderSink(dart.as(sink, ByteConversionSink)); | 1735 return new _Utf8EncoderSink(dart.as(sink, ByteConversionSink)); |
| 1733 } | 1736 } |
| 1734 bind(stream) { | 1737 bind(stream) { |
| 1735 return dart.as(super.bind(stream), async.Stream$(core.List$(core.int))); | 1738 return super.bind(stream); |
| 1736 } | 1739 } |
| 1737 } | 1740 } |
| 1738 class _Utf8Encoder extends core.Object { | 1741 class _Utf8Encoder extends core.Object { |
| 1739 _Utf8Encoder() { | 1742 _Utf8Encoder() { |
| 1740 this.withBufferSize(_Utf8Encoder._DEFAULT_BYTE_BUFFER_SIZE); | 1743 this.withBufferSize(_Utf8Encoder._DEFAULT_BYTE_BUFFER_SIZE); |
| 1741 } | 1744 } |
| 1742 withBufferSize(bufferSize) { | 1745 withBufferSize(bufferSize) { |
| 1743 this[_buffer] = _Utf8Encoder._createBuffer(bufferSize); | 1746 this[_buffer] = _Utf8Encoder._createBuffer(bufferSize); |
| 1744 this[_carry] = 0; | 1747 this[_carry] = 0; |
| 1745 this[_bufferIndex] = 0; | 1748 this[_bufferIndex] = 0; |
| (...skipping 185 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1931 startChunkedConversion(sink) { | 1934 startChunkedConversion(sink) { |
| 1932 let stringSink = null; | 1935 let stringSink = null; |
| 1933 if (dart.is(sink, StringConversionSink)) { | 1936 if (dart.is(sink, StringConversionSink)) { |
| 1934 stringSink = sink; | 1937 stringSink = sink; |
| 1935 } else { | 1938 } else { |
| 1936 stringSink = new StringConversionSink.from(sink); | 1939 stringSink = new StringConversionSink.from(sink); |
| 1937 } | 1940 } |
| 1938 return stringSink.asUtf8Sink(this[_allowMalformed]); | 1941 return stringSink.asUtf8Sink(this[_allowMalformed]); |
| 1939 } | 1942 } |
| 1940 bind(stream) { | 1943 bind(stream) { |
| 1941 return dart.as(super.bind(stream), async.Stream$(core.String)); | 1944 return super.bind(stream); |
| 1942 } | 1945 } |
| 1943 fuse(next) { | 1946 fuse(next) { |
| 1944 return super.fuse(next); | 1947 return super.fuse(next); |
| 1945 } | 1948 } |
| 1946 } | 1949 } |
| 1947 let _ONE_BYTE_LIMIT = 127; | 1950 let _ONE_BYTE_LIMIT = 127; |
| 1948 let _TWO_BYTE_LIMIT = 2047; | 1951 let _TWO_BYTE_LIMIT = 2047; |
| 1949 let _THREE_BYTE_LIMIT = 65535; | 1952 let _THREE_BYTE_LIMIT = 65535; |
| 1950 let _FOUR_BYTE_LIMIT = 1114111; | 1953 let _FOUR_BYTE_LIMIT = 1114111; |
| 1951 let _SURROGATE_MASK = 63488; | 1954 let _SURROGATE_MASK = 63488; |
| (...skipping 465 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2417 exports.LineSplitter = LineSplitter; | 2420 exports.LineSplitter = LineSplitter; |
| 2418 exports.StringConversionSink = StringConversionSink; | 2421 exports.StringConversionSink = StringConversionSink; |
| 2419 exports.ClosableStringSink = ClosableStringSink; | 2422 exports.ClosableStringSink = ClosableStringSink; |
| 2420 exports.UNICODE_REPLACEMENT_CHARACTER_RUNE = UNICODE_REPLACEMENT_CHARACTER_RUN
E; | 2423 exports.UNICODE_REPLACEMENT_CHARACTER_RUNE = UNICODE_REPLACEMENT_CHARACTER_RUN
E; |
| 2421 exports.UNICODE_BOM_CHARACTER_RUNE = UNICODE_BOM_CHARACTER_RUNE; | 2424 exports.UNICODE_BOM_CHARACTER_RUNE = UNICODE_BOM_CHARACTER_RUNE; |
| 2422 exports.UTF8 = UTF8; | 2425 exports.UTF8 = UTF8; |
| 2423 exports.Utf8Codec = Utf8Codec; | 2426 exports.Utf8Codec = Utf8Codec; |
| 2424 exports.Utf8Encoder = Utf8Encoder; | 2427 exports.Utf8Encoder = Utf8Encoder; |
| 2425 exports.Utf8Decoder = Utf8Decoder; | 2428 exports.Utf8Decoder = Utf8Decoder; |
| 2426 })(convert || (convert = {})); | 2429 })(convert || (convert = {})); |
| OLD | NEW |