| Index: test/codegen/lib/convert/streamed_conversion_json_encode1_test.dart
|
| diff --git a/test/codegen/lib/convert/streamed_conversion_json_encode1_test.dart b/test/codegen/lib/convert/streamed_conversion_json_encode1_test.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..373e29f2cd8523a90944cbbcb56f50bd36ae3f4f
|
| --- /dev/null
|
| +++ b/test/codegen/lib/convert/streamed_conversion_json_encode1_test.dart
|
| @@ -0,0 +1,78 @@
|
| +// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
|
| +// for details. All rights reserved. Use of this source code is governed by a
|
| +// BSD-style license that can be found in the LICENSE file.
|
| +
|
| +import "package:expect/expect.dart";
|
| +import 'dart:async';
|
| +import 'dart:convert';
|
| +import "package:async_helper/async_helper.dart";
|
| +
|
| +final TESTS = [
|
| + [ 5, '5' ],
|
| + [ -42, '-42' ],
|
| + [ 3.14, '3.14' ],
|
| + [ true, 'true' ],
|
| + [ false, 'false' ],
|
| + [ null, 'null' ],
|
| + [ 'quote"or\'', '"quote\\"or\'"' ],
|
| + [ '', '""' ],
|
| + [ [], "[]" ],
|
| + [ [3, -4.5, true, "hi", false], '[3,-4.5,true,"hi",false]' ],
|
| + [ [null], "[null]" ],
|
| + [ [[null]], "[[null]]" ],
|
| + [ [[3]], "[[3]]" ],
|
| + [ {}, "{}" ],
|
| + [ { "x": 3, "y": 4.5, "z": "hi", "u": true, "v": false },
|
| + '{"x":3,"y":4.5,"z":"hi","u":true,"v":false}' ],
|
| + [ { "x": null }, '{"x":null}' ],
|
| + [ { "x": {} }, '{"x":{}}' ],
|
| + // Note that -0.0 won't be treated the same in JS. The Json spec seems to
|
| + // allow it, though.
|
| + // TODO(rnystrom): Changed to "0". See above comment.
|
| + [ { "hi there": 499, "'":-0.0 }, '{"hi there":499,"\'":0}' ],
|
| + [ r'\foo', r'"\\foo"' ],
|
| + ];
|
| +
|
| +Stream<String> encode(Object o) {
|
| + var encoder = new JsonEncoder();
|
| + StreamController controller;
|
| + controller = new StreamController(onListen: () {
|
| + controller.add(o);
|
| + controller.close();
|
| + });
|
| + return controller.stream.transform(encoder);
|
| +}
|
| +
|
| +void testNoPause(String expected, Object o) {
|
| + asyncStart();
|
| + Stream stream = encode(o);
|
| + stream.toList().then((list) {
|
| + StringBuffer buffer = new StringBuffer();
|
| + buffer.writeAll(list);
|
| + Expect.stringEquals(expected, buffer.toString());
|
| + asyncEnd();
|
| + });
|
| +}
|
| +
|
| +void testWithPause(String expected, Object o) {
|
| + asyncStart();
|
| + Stream stream = encode(o);
|
| + StringBuffer buffer = new StringBuffer();
|
| + var sub;
|
| + sub = stream.listen((x) {
|
| + buffer.write(x);
|
| + sub.pause(new Future.delayed(Duration.ZERO));
|
| + }, onDone: () {
|
| + Expect.stringEquals(expected, buffer.toString());
|
| + asyncEnd();
|
| + });
|
| +}
|
| +
|
| +void main() {
|
| + for (var test in TESTS) {
|
| + var o = test[0];
|
| + var expected = test[1];
|
| + testNoPause(expected, o);
|
| + testWithPause(expected, o);
|
| + }
|
| +}
|
|
|