diff --git a/commons/src/main/java/org/archive/io/RecordingInputStream.java b/commons/src/main/java/org/archive/io/RecordingInputStream.java index f28f3d27..8fea7f52 100644 --- a/commons/src/main/java/org/archive/io/RecordingInputStream.java +++ b/commons/src/main/java/org/archive/io/RecordingInputStream.java @@ -339,4 +339,13 @@ public class RecordingInputStream public void setLimits(long hardMax, long timeoutMs, long maxRateKBps) { recordingOutputStream.setLimits(hardMax, timeoutMs, maxRateKBps); } + + /** + * Expose the amount of in-memory buffering used by the internal + * recording stream. + * @return int buffer size + */ + public int getRecordedBufferLength() { + return recordingOutputStream.getBufferLength(); + } } diff --git a/commons/src/main/java/org/archive/util/Recorder.java b/commons/src/main/java/org/archive/util/Recorder.java index 4f8a30de..96f197f9 100644 --- a/commons/src/main/java/org/archive/util/Recorder.java +++ b/commons/src/main/java/org/archive/util/Recorder.java @@ -382,7 +382,7 @@ public class Recorder { InputStream ris = getContentReplayInputStream(); ReplayCharSequence rcs = new GenericReplayCharSequence( ris, - this.ros.getBufferLength()/2, + this.getRecordedInput().getRecordedBufferLength()/2, this.backingFileBasename + RECORDING_OUTPUT_STREAM_SUFFIX, requestedCharset); ris.close();