Merge branch 'x0id/jinterface_transport_factory'

* x0id/jinterface_transport_factory:
  jinterface: transport factory implementation
  fix typo error from recent merge

OTP-12686

1 files changed, 12 insertions, 1 deletions

diff --git a/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpOutputStream.java b/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpOutputStream.java
index b8493b57ff..2ec583ff5c 100644
--- a/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpOutputStream.java
+++ b/lib/jinterface/java_src/com/ericsson/otp/erlang/OtpOutputStream.java
@@ -21,6 +21,7 @@ package com.ericsson.otp.erlang;
 // import java.io.OutputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.io.OutputStream;
 import java.io.UnsupportedEncodingException;
 import java.math.BigDecimal;
 import java.math.BigInteger;
@@ -202,6 +203,16 @@ public class OtpOutputStream extends ByteArrayOutputStream {
         super.count += len;
     }
 
+    @Override
+    public synchronized void writeTo(OutputStream out) throws IOException {
+        super.writeTo(out);
+    }
+
+    public synchronized void writeToAndFlush(OutputStream out) throws IOException {
+        super.writeTo(out);
+        out.flush();
+    }
+
     /**
      * Write the low byte of a value to the stream.
      *
@@ -887,7 +898,7 @@ public class OtpOutputStream extends ByteArrayOutputStream {
         if (oos.size() < 5) {
             // fast path for small terms
             try {
-                oos.writeTo(this);
+                oos.writeToAndFlush(this);
                 // if the term is written as a compressed term, the output
                 // stream is closed, so we do this here, too
                 close();