code review updates

rhencke · Apr 16, 2018 · 5753cf1 · 5753cf1
1 parent 30c58c7
commit 5753cf1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,4 @@
-## 1.6.4+1
+## 1.6.5
 
 * Fix an issue with `JsonDocumentTransformer.bind` where it created an internal
   stream channel which didn't get a properly inferred type for its `sink`.

diff --git a/lib/src/json_document_transformer.dart b/lib/src/json_document_transformer.dart
@@ -38,8 +38,8 @@ class JsonDocumentTransformer
 
   StreamChannel<Object> bind(StreamChannel<String> channel) {
     var stream = channel.stream.map(_codec.decode);
-    var sink = new StreamSinkTransformer.fromHandlers(
-        handleData: (Object data, EventSink<String> sink) {
+    var sink = new StreamSinkTransformer<Object, String>.fromHandlers(
+        handleData: (data, sink) {
       sink.add(_codec.encode(data));
     }).bind(channel.sink);
     return new StreamChannel.withCloseGuarantee(stream, sink);

diff --git a/pubspec.yaml b/pubspec.yaml
@@ -1,5 +1,5 @@
 name: stream_channel
-version: 1.6.4+1
+version: 1.6.5
 description: An abstraction for two-way communication channels.
 author: Dart Team <[email protected]>
 homepage: https://github.com/dart-lang/stream_channel