Fix the type args for StreamChannel.transform(). (flutter#7)

Closes flutter#6

Author: nex3

CHANGELOG.md

@@ -1,3 +1,9 @@
+## 1.6.1
+
+* Fix the type of `StreamChannel.transform()`. This previously inverted the
+  generic parameters, so it only really worked with transformers where both
+  generic types were identical.
+
 ## 1.6.0
 
 * `Disconnector.disconnect()` now returns a future that completes when all the

lib/stream_channel.dart

@@ -108,7 +108,8 @@ abstract class StreamChannel<T> {
   /// Transforms [this] using [transformer].
   ///
   /// This is identical to calling `transformer.bind(channel)`.
-  StreamChannel transform(StreamChannelTransformer<T, dynamic> transformer);
+  StreamChannel/*<S>*/ transform/*<S>*/(
+      StreamChannelTransformer<dynamic/*=S*/, T> transformer);
 
   /// Transforms only the [stream] component of [this] using [transformer].
   StreamChannel<T> transformStream(StreamTransformer<T, T> transformer);
@@ -152,7 +153,8 @@ abstract class StreamChannelMixin<T> implements StreamChannel<T> {
     other.stream.pipe(sink);
   }
 
-  StreamChannel transform(StreamChannelTransformer<T, dynamic> transformer) =>
+  StreamChannel/*<S>*/ transform/*<S>*/(
+          StreamChannelTransformer<dynamic/*=S*/, T> transformer) =>
       transformer.bind(this);
 
   StreamChannel<T> transformStream(StreamTransformer<T, T> transformer) =>

pubspec.yaml

@@ -1,5 +1,5 @@
 name: stream_channel
-version: 1.6.0
+version: 1.6.1
 description: An abstraction for two-way communication channels.
 author: Dart Team <[email protected]>
 homepage: https://github.com/dart-lang/stream_channel

test/json_document_transformer_test.dart

@@ -11,11 +11,11 @@ import 'package:test/test.dart';
 void main() {
   var streamController;
   var sinkController;
-  var channel;
+  StreamChannel<String> channel;
   setUp(() {
     streamController = new StreamController();
     sinkController = new StreamController();
-    channel = new StreamChannel(
+    channel = new StreamChannel<String>(
         streamController.stream, sinkController.sink);
   });