Index: lib/src/json_document_transformer.dart |
diff --git a/lib/src/json_document_transformer.dart b/lib/src/json_document_transformer.dart |
index c62c597cb549c8c4b48746faf5116b94edd76b12..86b9ae71c34b966f7f56424d810a0277790288a3 100644 |
--- a/lib/src/json_document_transformer.dart |
+++ b/lib/src/json_document_transformer.dart |
@@ -40,6 +40,6 @@ class JsonDocumentTransformer |
var sink = new StreamSinkTransformer.fromHandlers(handleData: (data, sink) { |
sink.add(_codec.encode(data)); |
}).bind(channel.sink); |
- return new StreamChannel(stream, sink); |
+ return new StreamChannel.withCloseGuarantee(stream, sink); |
} |
} |