| Index: test/stream_channel_test.dart
|
| diff --git a/test/stream_channel_test.dart b/test/stream_channel_test.dart
|
| index 2a6566ac7cb5bbd04991ad8fa4ef4b8ce3cbe435..41f4c32ec39ca4bdf253ecc59af41a3e6dd98b65 100644
|
| --- a/test/stream_channel_test.dart
|
| +++ b/test/stream_channel_test.dart
|
| @@ -41,13 +41,13 @@ void main() {
|
| expect(sinkController.stream.toList(), completion(equals([4, 5, 6])));
|
| });
|
|
|
| - test("transform() transforms the channel", () {
|
| + test("transform() transforms the channel", () async {
|
| var transformed = channel.transform(
|
| new StreamChannelTransformer.fromCodec(UTF8));
|
|
|
| streamController.add([102, 111, 111, 98, 97, 114]);
|
| streamController.close();
|
| - expect(transformed.stream.toList(), completion(equals(["foobar"])));
|
| + expect(await transformed.stream.toList(), equals(["foobar"]));
|
|
|
| transformed.sink.add("fblthp");
|
| transformed.sink.close();
|
| @@ -55,12 +55,12 @@ void main() {
|
| completion(equals([[102, 98, 108, 116, 104, 112]])));
|
| });
|
|
|
| - test("transformStream() transforms only the stream", () {
|
| + test("transformStream() transforms only the stream", () async {
|
| var transformed = channel.transformStream(UTF8.decoder);
|
|
|
| streamController.add([102, 111, 111, 98, 97, 114]);
|
| streamController.close();
|
| - expect(transformed.stream.toList(), completion(equals(["foobar"])));
|
| + expect(await transformed.stream.toList(), equals(["foobar"]));
|
|
|
| transformed.sink.add("fblthp");
|
| transformed.sink.close();
|
| @@ -68,14 +68,14 @@ void main() {
|
| completion(equals(["fblthp"])));
|
| });
|
|
|
| - test("transformSink() transforms only the sink", () {
|
| + test("transformSink() transforms only the sink", () async {
|
| var transformed = channel.transformSink(
|
| new StreamSinkTransformer.fromStreamTransformer(UTF8.encoder));
|
|
|
| streamController.add([102, 111, 111, 98, 97, 114]);
|
| streamController.close();
|
| - expect(transformed.stream.toList(),
|
| - completion(equals([[102, 111, 111, 98, 97, 114]])));
|
| + expect(await transformed.stream.toList(),
|
| + equals([[102, 111, 111, 98, 97, 114]]));
|
|
|
| transformed.sink.add("fblthp");
|
| transformed.sink.close();
|
|
|