commit 6e82f041533acc45b39d2dda3fe89255d4799858
author Jacob MacDonald <jakemac@google.com> Tue May 01 09:58:15 2018 -0700
committer Jacob MacDonald <jakemac@google.com> Tue May 01 09:58:15 2018 -0700
tree 513d9c05e792f9da1d4af7eac13117ee58c8d839
parent 58d19ee7f52417711dd48e478651c5d6eeb85dc7

fix some stream channel tests

.gitignore

diff --git a/.gitignore b/.gitignore
index 25a1df3..1447012 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,4 +1,5 @@
 .buildlog
+.dart_tool/
 .DS_Store
 .idea
 .pub/

test/stream_channel_test.dart

diff --git a/test/stream_channel_test.dart b/test/stream_channel_test.dart
index b8ebcbd..c29002f 100644
--- a/test/stream_channel_test.dart
+++ b/test/stream_channel_test.dart
@@ -10,9 +10,9 @@
 import 'package:test/test.dart';
 
 void main() {
-  var streamController;
-  var sinkController;
-  var channel;
+  StreamController streamController;
+  StreamController sinkController;
+  StreamChannel channel;
   setUp(() {
     streamController = new StreamController();
     sinkController = new StreamController();
@@ -58,36 +58,35 @@
   });
 
   test("transformStream() transforms only the stream", () async {
-    var transformed = channel.transformStream(UTF8.decoder);
+    var transformed =
+        channel.cast<String>().transformStream(const LineSplitter());
 
-    streamController.add([102, 111, 111, 98, 97, 114]);
+    streamController.add("hello world");
+    streamController.add(" what\nis");
+    streamController.add("\nup");
     streamController.close();
-    expect(await transformed.stream.toList(), equals(["foobar"]));
+    expect(await transformed.stream.toList(),
+        equals(["hello world what", "is", "up"]));
 
-    transformed.sink.add("fblthp");
+    transformed.sink.add("fbl\nthp");
     transformed.sink.close();
-    expect(sinkController.stream.toList(), completion(equals(["fblthp"])));
+    expect(sinkController.stream.toList(), completion(equals(["fbl\nthp"])));
   });
 
   test("transformSink() transforms only the sink", () async {
-    var transformed = channel.transformSink(
-        new StreamSinkTransformer.fromStreamTransformer(UTF8.encoder));
+    var transformed = channel.cast<String>().transformSink(
+        new StreamSinkTransformer.fromStreamTransformer(const LineSplitter()));
 
-    streamController.add([102, 111, 111, 98, 97, 114]);
+    streamController.add("fbl\nthp");
     streamController.close();
-    expect(
-        await transformed.stream.toList(),
-        equals([
-          [102, 111, 111, 98, 97, 114]
-        ]));
+    expect(await transformed.stream.toList(), equals(["fbl\nthp"]));
 
-    transformed.sink.add("fblthp");
+    transformed.sink.add("hello world");
+    transformed.sink.add(" what\nis");
+    transformed.sink.add("\nup");
     transformed.sink.close();
-    expect(
-        sinkController.stream.toList(),
-        completion(equals([
-          [102, 98, 108, 116, 104, 112]
-        ])));
+    expect(sinkController.stream.toList(),
+        completion(equals(["hello world what", "is", "up"])));
   });
 
   test("changeStream() changes the stream", () {