| Index: pkg/analysis_server/lib/src/channel/channel.dart
|
| diff --git a/pkg/analysis_server/lib/src/channel/channel.dart b/pkg/analysis_server/lib/src/channel/channel.dart
|
| index f3e473de8458edfe0545bf5ceddb340be4c0e2e5..bee6f359fe7df2d4420b771eba183c1b4dad40b9 100644
|
| --- a/pkg/analysis_server/lib/src/channel/channel.dart
|
| +++ b/pkg/analysis_server/lib/src/channel/channel.dart
|
| @@ -85,12 +85,13 @@ abstract class ClientCommunicationChannel {
|
| * Instances of the class [JsonStreamDecoder] convert JSON strings to JSON
|
| * maps.
|
| */
|
| -class JsonStreamDecoder extends Converter<String, Map> {
|
| +class JsonStreamDecoder extends
|
| + ChunkedConverter<String, Map, String, Map> {
|
| @override
|
| Map convert(String text) => JSON.decode(text);
|
|
|
| @override
|
| - ChunkedConversionSink startChunkedConversion(Sink sink) =>
|
| + ChunkedConversionSink<String> startChunkedConversion(Sink<Map> sink) =>
|
| new ChannelChunkSink<String, Map>(this, sink);
|
| }
|
|
|
| @@ -98,24 +99,26 @@ class JsonStreamDecoder extends Converter<String, Map> {
|
| * Instances of the class [NotificationConverter] convert JSON maps to
|
| * [Notification]s.
|
| */
|
| -class NotificationConverter extends Converter<Map, Notification> {
|
| +class NotificationConverter extends
|
| + ChunkedConverter<Map, Notification, Map, Notification> {
|
| @override
|
| Notification convert(Map json) => new Notification.fromJson(json);
|
|
|
| @override
|
| - ChunkedConversionSink startChunkedConversion(Sink sink) =>
|
| + ChunkedConversionSink<Map> startChunkedConversion(Sink<Notification> sink) =>
|
| new ChannelChunkSink<Map, Notification>(this, sink);
|
| }
|
|
|
| /**
|
| * Instances of the class [ResponseConverter] convert JSON maps to [Response]s.
|
| */
|
| -class ResponseConverter extends Converter<Map, Response> {
|
| +class ResponseConverter extends
|
| + ChunkedConverter<Map, Response, Map, Response> {
|
| @override
|
| Response convert(Map json) => new Response.fromJson(json);
|
|
|
| @override
|
| - ChunkedConversionSink startChunkedConversion(Sink sink) =>
|
| + ChunkedConversionSink<Map> startChunkedConversion(Sink<Response> sink) =>
|
| new ChannelChunkSink<Map, Response>(this, sink);
|
| }
|
|
|
|
|