Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed the output stream incomplete data by explicitly flushing the OutputStreamWriter

Browse Source
This commit is contained in:
Alex Antonov
2014-12-04 16:46:15 -06:00
parent b041cffe5d
commit bf8d99d7e4
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-web/src/main/java/org/springframework/http/converter/protobuf/ProtobufHttpMessageConverter.java
View File

@@ -166,16 +166,24 @@ public class ProtobufHttpMessageConverter extends AbstractHttpMessageConverter<M
Charset charset = getCharset(contentType); Charset charset = getCharset(contentType);
if (MediaType.TEXT_HTML.isCompatibleWith(contentType)) { if (MediaType.TEXT_HTML.isCompatibleWith(contentType)) {
HtmlFormat.print(message, new OutputStreamWriter(outputMessage.getBody(), charset)); final OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputMessage.getBody(), charset);
HtmlFormat.print(message, outputStreamWriter);
outputStreamWriter.flush();
} }
else if (MediaType.APPLICATION_JSON.isCompatibleWith(contentType)) { else if (MediaType.APPLICATION_JSON.isCompatibleWith(contentType)) {
JsonFormat.print(message, new OutputStreamWriter(outputMessage.getBody(), charset)); final OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputMessage.getBody(), charset);
JsonFormat.print(message, outputStreamWriter);
outputStreamWriter.flush();
} }
else if (MediaType.TEXT_PLAIN.isCompatibleWith(contentType)) { else if (MediaType.TEXT_PLAIN.isCompatibleWith(contentType)) {
TextFormat.print(message, new OutputStreamWriter(outputMessage.getBody(), charset)); final OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputMessage.getBody(), charset);
TextFormat.print(message, outputStreamWriter);
outputStreamWriter.flush();
} }
else if (MediaType.APPLICATION_XML.isCompatibleWith(contentType)) { else if (MediaType.APPLICATION_XML.isCompatibleWith(contentType)) {
XmlFormat.print(message, new OutputStreamWriter(outputMessage.getBody(), charset)); final OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputMessage.getBody(), charset);
XmlFormat.print(message, outputStreamWriter);
outputStreamWriter.flush();
} }
else if (PROTOBUF.isCompatibleWith(contentType)) { else if (PROTOBUF.isCompatibleWith(contentType)) {
setProtoHeader(outputMessage, message); setProtoHeader(outputMessage, message);