| Index: tests/lib_strong/async/stream_transformation_broadcast_test.dart
|
| diff --git a/tests/lib_strong/async/stream_transformation_broadcast_test.dart b/tests/lib_strong/async/stream_transformation_broadcast_test.dart
|
| index ce9c882e4fcb11ec3a0eec6904bdce9e6304098c..330901efd8041f336fceebe926afb558bf593ab2 100644
|
| --- a/tests/lib_strong/async/stream_transformation_broadcast_test.dart
|
| +++ b/tests/lib_strong/async/stream_transformation_broadcast_test.dart
|
| @@ -12,17 +12,16 @@ import "package:expect/expect.dart";
|
|
|
| main() {
|
| testStream("singlesub", () => new StreamController(), (c) => c.stream);
|
| - testStream("broadcast", () => new StreamController.broadcast(),
|
| - (c) => c.stream);
|
| + testStream(
|
| + "broadcast", () => new StreamController.broadcast(), (c) => c.stream);
|
| testStream("asBroadcast", () => new StreamController(),
|
| - (c) => c.stream.asBroadcastStream());
|
| + (c) => c.stream.asBroadcastStream());
|
| testStream("broadcast.asBroadcast", () => new StreamController.broadcast(),
|
| - (c) => c.stream.asBroadcastStream());
|
| + (c) => c.stream.asBroadcastStream());
|
| }
|
|
|
| -void testStream(String name,
|
| - StreamController create(),
|
| - Stream getStream(controller)) {
|
| +void testStream(
|
| + String name, StreamController create(), Stream getStream(controller)) {
|
| test("$name-map", () {
|
| var c = create();
|
| var s = getStream(c);
|
| @@ -77,9 +76,10 @@ void testStream(String name,
|
| var c = create();
|
| var s = getStream(c);
|
| // TODO: find name of default transformer
|
| - var t = new StreamTransformer.fromHandlers(
|
| - handleData: (value, EventSink sink) { sink.add(value); }
|
| - );
|
| + var t =
|
| + new StreamTransformer.fromHandlers(handleData: (value, EventSink sink) {
|
| + sink.add(value);
|
| + });
|
| Stream newStream = s.transform(t);
|
| Expect.equals(s.isBroadcast, newStream.isBroadcast);
|
| newStream.single.then(expectAsync((v) {
|
| @@ -187,13 +187,12 @@ void testStream(String name,
|
| if (name.startsWith("singlesub")) return;
|
|
|
| test("$name-skip-multilisten", () {
|
| - if (name.startsWith("singlesub") ||
|
| - name.startsWith("asBroadcast")) return;
|
| + if (name.startsWith("singlesub") || name.startsWith("asBroadcast")) return;
|
| var c = create();
|
| var s = getStream(c);
|
| Stream newStream = s.skip(5);
|
| // Listen immediately, to ensure that an asBroadcast stream is started.
|
| - var sub = newStream.listen((_){});
|
| + var sub = newStream.listen((_) {});
|
| int i = 0;
|
| var expect1 = 11;
|
| var expect2 = 21;
|
| @@ -234,7 +233,7 @@ void testStream(String name,
|
| var s = getStream(c);
|
| Stream newStream = s.take(10);
|
| // Listen immediately, to ensure that an asBroadcast stream is started.
|
| - var sub = newStream.listen((_){});
|
| + var sub = newStream.listen((_) {});
|
| int i = 0;
|
| var expect1 = 6;
|
| var expect2 = 11;
|
| @@ -273,13 +272,12 @@ void testStream(String name,
|
| });
|
|
|
| test("$name-skipWhile-multilisten", () {
|
| - if (name.startsWith("singlesub") ||
|
| - name.startsWith("asBroadcast")) return;
|
| + if (name.startsWith("singlesub") || name.startsWith("asBroadcast")) return;
|
| var c = create();
|
| var s = getStream(c);
|
| Stream newStream = s.skipWhile((x) => (x % 10) != 1);
|
| // Listen immediately, to ensure that an asBroadcast stream is started.
|
| - var sub = newStream.listen((_){});
|
| + var sub = newStream.listen((_) {});
|
| int i = 0;
|
| var expect1 = 11;
|
| var expect2 = 21;
|
| @@ -320,9 +318,9 @@ void testStream(String name,
|
| var s = getStream(c);
|
| Stream newStream = s.takeWhile((x) => (x % 10) != 5);
|
| // Listen immediately, to ensure that an asBroadcast stream is started.
|
| - var sub = newStream.listen((_){});
|
| + var sub = newStream.listen((_) {});
|
| int i = 0;
|
| - // Non-overlapping ranges means the test must not remember its first
|
| + // Non-overlapping ranges means the test must not remember its first
|
| // failure.
|
| var expect1 = 6;
|
| var expect2 = 16;
|
|
|