diff --git a/src/main/java/org/nustaq/serialization/coders/FSTStreamDecoder.java b/src/main/java/org/nustaq/serialization/coders/FSTStreamDecoder.java index bde0f9dc..2b204024 100644 --- a/src/main/java/org/nustaq/serialization/coders/FSTStreamDecoder.java +++ b/src/main/java/org/nustaq/serialization/coders/FSTStreamDecoder.java @@ -452,6 +452,10 @@ public void setInputStream(InputStream in) { clnames.clear(); } + public InputStream getInputStream() { + return input; + } + @Override public void resetToCopyOf(byte[] bytes, int off, int len) { input.reset(); diff --git a/src/main/java/org/nustaq/serialization/coders/FSTStreamEncoder.java b/src/main/java/org/nustaq/serialization/coders/FSTStreamEncoder.java index 521f89bd..3848c310 100644 --- a/src/main/java/org/nustaq/serialization/coders/FSTStreamEncoder.java +++ b/src/main/java/org/nustaq/serialization/coders/FSTStreamEncoder.java @@ -526,6 +526,10 @@ public void setOutstream(OutputStream outstream) { else buffout.setOutstream(outstream); } + + public OutputStream getOutstream() { + return buffout; + } /** * writes current buffer to underlying output and resets buffer.