You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tuscany.apache.org by rf...@apache.org on 2012/03/21 20:08:48 UTC
svn commit: r1303509 -
/tuscany/sca-java-2.x/trunk/modules/databinding-json/src/main/java/org/apache/tuscany/sca/databinding/json/jackson/JSON2OutputStream.java
Author: rfeng
Date: Wed Mar 21 19:08:47 2012
New Revision: 1303509
URL: http://svn.apache.org/viewvc?rev=1303509&view=rev
Log:
Handle inputstream to outputstream copy
Modified:
tuscany/sca-java-2.x/trunk/modules/databinding-json/src/main/java/org/apache/tuscany/sca/databinding/json/jackson/JSON2OutputStream.java
Modified: tuscany/sca-java-2.x/trunk/modules/databinding-json/src/main/java/org/apache/tuscany/sca/databinding/json/jackson/JSON2OutputStream.java
URL: http://svn.apache.org/viewvc/tuscany/sca-java-2.x/trunk/modules/databinding-json/src/main/java/org/apache/tuscany/sca/databinding/json/jackson/JSON2OutputStream.java?rev=1303509&r1=1303508&r2=1303509&view=diff
==============================================================================
--- tuscany/sca-java-2.x/trunk/modules/databinding-json/src/main/java/org/apache/tuscany/sca/databinding/json/jackson/JSON2OutputStream.java (original)
+++ tuscany/sca-java-2.x/trunk/modules/databinding-json/src/main/java/org/apache/tuscany/sca/databinding/json/jackson/JSON2OutputStream.java Wed Mar 21 19:08:47 2012
@@ -19,6 +19,8 @@
package org.apache.tuscany.sca.databinding.json.jackson;
+import java.io.InputStream;
+import java.io.IOException;
import java.io.OutputStream;
import org.apache.tuscany.sca.databinding.PushTransformer;
@@ -48,7 +50,19 @@ public class JSON2OutputStream implement
if (source == null) {
return;
}
- if (source instanceof JsonNode) {
+ if (source instanceof InputStream) {
+ try {
+ InputStream input = (InputStream) source;
+ byte[] buffer = new byte[4096];
+ int n = 0;
+ while (-1 != (n = input.read(buffer))) {
+ sink.write(buffer, 0, n);
+ }
+ input.close();
+ } catch(IOException e) {
+ throw new TransformationException(e);
+ }
+ } else if (source instanceof JsonNode) {
JacksonHelper.write((JsonNode)source, sink);
} else if (source instanceof JsonParser) {
JacksonHelper.write((JsonParser)source, sink);