Небольшая пауза между переходами циклов с движком R3 при использовании с ExoPlayer (Android)

Я интегрировал библиотеку Rubberband с ExoPlayer для настройки высоты и темпа в проекте Android. При использовании движка R2 аудиопетля работает гладко, как и ожидалось. Однако при переключении на движок R3 (OptionEngineFiner) с включенной петлей в exoplayer наблюдается небольшая, но заметная пауза между концом и началом аудиофайла во время переходов по петле. Это поведение не наблюдается с движком R2 (OptionEngineFaster) и затрагивает только движок R3, что приводит к несовместимому опыту петли. Есть ли что-то, что я упускаю с движком R3? Я пробовал демо-приложение Rubberband, и там петля работает нормально.

Мой код AudioProcessor для exoplayer:

rb = RubberBandStretcher(
                    inputAudioFormat.sampleRate,
                    inputAudioFormat.channelCount,
                    RubberBandStretcher.OptionProcessRealTime.or(RubberBandStretcher.OptionEngineFiner).or(RubberBandStretcher.OptionWindowShort).or(RubberBandStretcher.OptionFormantPreserved).or(RubberBandStretcher.OptionPitchHighConsistency),
                    speed.toDouble(),
                    pitch.toDouble()
                )

Весь код для Audio Processor

class RubberBandAudioProcessor : AudioProcessor {

    /** Указывает, что частота дискретизации выходного сигнала должна быть такой же, как и у входного.  */
    val SAMPLE_RATE_NO_CHANGE = -1

    /** Порог, ниже которого разница между двумя факторами высоты/скорости незначительна.  */
    private val CLOSE_THRESHOLD = 0.0001f

    /**
     * Минимальное количество выходных байтов, необходимых для расчета временной шкалы с использованием
     * входных и выходных подсчетов байтов, а не с использованием текущей скорости воспроизведения.
     */
    private val MIN_BYTES_FOR_DURATION_SCALING_CALCULATION = 1024

    private var pendingOutputSampleRate = 0
    private var speed = 1f
    private var pitch = 1f

    private var pendingInputAudioFormat: AudioProcessor.AudioFormat
    private var pendingOutputAudioFormat: AudioProcessor.AudioFormat
    private var inputAudioFormat: AudioProcessor.AudioFormat
    private var outputAudioFormat: AudioProcessor.AudioFormat

    private var pendingSonicRecreation = false
    private var rb: RubberBandStretcher? = null
    private var buffer: ByteBuffer
    private var shortBuffer: ShortBuffer
    private var outputBuffer: ByteBuffer
    private var inputBytes: Long = 0
    private var outputBytes: Long = 0
    private var inputEnded = false

    /** Создает новый аудио процессор Sonic.  */
    init {
        speed = 1f
        pitch = 1f
        pendingInputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        pendingOutputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        inputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        outputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        buffer = AudioProcessor.EMPTY_BUFFER
        shortBuffer = buffer.asShortBuffer()
        outputBuffer = AudioProcessor.EMPTY_BUFFER
        pendingOutputSampleRate = SAMPLE_RATE_NO_CHANGE
    }

    /**
     * Устанавливает целевую скорость воспроизведения. Этот метод может быть вызван только после обработки данных через
     * процессор. Значение, возвращаемое [.isActive], может измениться, и процессор должен быть
     * [очищен][.flush] перед добавлением новых данных в очередь.
     *
     * @param speed Целевой коэффициент, с которым воспроизведение должно ускориться.
     */
    fun setSpeed(speed: Float) {
        if (this.speed != speed) {
            this.speed = 1/speed
            rb?.timeRatio = 1/speed.toDouble()
            pendingSonicRecreation = true
        }
    }

    /**
     * Устанавливает целевую высоту воспроизведения. Этот метод может быть вызван только после обработки данных через
     * процессор. Значение, возвращаемое [.isActive], может измениться, и процессор должен быть
     * [очищен][.flush] перед добавлением новых данных в очередь.
     *
     * @param pitch Целевая высота.
     */
    fun setPitch(pitch: Float) {
        if (this.pitch != pitch) {
            this.pitch = pitch
            rb?.pitchScale=pitch.toDouble()
            pendingSonicRecreation = true
        }
    }

    /**
     * Устанавливает частоту дискретизации для выходного аудио в герцах. Передайте [.SAMPLE_RATE_NO_CHANGE] для вывода
     * аудио на той же частоте дискретизации, что и вход. После вызова этого метода вызовите [ ][.configure], чтобы настроить процессор с новой частотой дискретизации.
     *
     * @param sampleRateHz Частота дискретизации для выходного аудио в герцах.
     * @see .configure
     */
    fun setOutputSampleRateHz(sampleRateHz: Int) {
        pendingOutputSampleRate = sampleRateHz
    }

    /**
     * Возвращает длительность медиа, соответствующую указанной длительности воспроизведения, с учетом настройки скорости.
     *
     * Масштабирование, выполняемое этим методом, будет использовать фактическую скорость воспроизведения, достигнутую
     * аудио процессором, в среднем, с момента последнего очищения. Это может немного отличаться от
     * целевой скорости воспроизведения.
     *
     * @param playoutDuration Длительность воспроизведения для масштабирования.
     * @return Соответствующая длительность медиа, в тех же единицах, что и `duration`.
     */
    fun getMediaDuration(playoutDuration: Long): Long {
        return if (outputBytes >= MIN_BYTES_FOR_DURATION_SCALING_CALCULATION) {
            val processedInputBytes = inputBytes - Assertions.checkNotNull(rb).samplesRequired
            if (outputAudioFormat.sampleRate == inputAudioFormat.sampleRate) Util.scaleLargeTimestamp(
                playoutDuration,
                processedInputBytes,
                outputBytes
            ) else Util.scaleLargeTimestamp(
                playoutDuration,
                processedInputBytes * outputAudioFormat.sampleRate,
                outputBytes * inputAudioFormat.sampleRate
            )
        } else {
            (speed.toDouble() * playoutDuration).toLong()
        }
    }

    @Throws(UnhandledAudioFormatException::class)
    override fun configure(inputAudioFormat: AudioProcessor.AudioFormat): AudioProcessor.AudioFormat {
        if (inputAudioFormat.encoding != C.ENCODING_PCM_16BIT) {
            throw UnhandledAudioFormatException(inputAudioFormat)
        }
        val outputSampleRateHz =
            if (pendingOutputSampleRate == SAMPLE_RATE_NO_CHANGE) inputAudioFormat.sampleRate else pendingOutputSampleRate
        pendingInputAudioFormat = inputAudioFormat
        pendingOutputAudioFormat = AudioProcessor.AudioFormat(
            outputSampleRateHz,
            inputAudioFormat.channelCount,
            C.ENCODING_PCM_16BIT
        )

        pendingSonicRecreation = true
        return pendingOutputAudioFormat
    }

    override fun isActive(): Boolean {
        val outputSampleRate = pendingOutputAudioFormat.sampleRate
        val inputSampleRate = pendingInputAudioFormat.sampleRate
        val speedDifference = abs(speed - 1f)
        val pitchDifference = abs(pitch - 1f)

        val isOutputSampleRateValid = outputSampleRate != Format.NO_VALUE
        val isSpeedChanged = speedDifference >= CLOSE_THRESHOLD
        val isPitchChanged = pitchDifference >= CLOSE_THRESHOLD
        val isSampleRateDifferent = outputSampleRate != inputSampleRate
        return (isOutputSampleRateValid
                && (isSpeedChanged || isPitchChanged || isSampleRateDifferent))
    }

    override fun queueInput(inputBuffer: ByteBuffer) {
        if (!inputBuffer.hasRemaining()) {
            return
        }
        val rb = Assertions.checkNotNull(rb)
        val shortBuffer = inputBuffer.asShortBuffer()
        val inputSize = inputBuffer.remaining()
        inputBytes += inputSize.toLong()
        rb.process(shortBuffer, inputAudioFormat.channelCount, false)
        inputBuffer.position(inputBuffer.position() + inputSize)
    }

    override fun queueEndOfStream() {
        Log.e("RUBBERBANDAUDIOPROCESSOR","QueueEndOfStream");
        if (rb != null) {
            rb!!.queueEndOfStream()
        }
        inputEnded = true
    }

    override fun getOutput(): ByteBuffer {

        val rb = rb
        val channelCount = inputAudioFormat.channelCount
        val samplesRequired = rb?.samplesRequired
        if (rb != null) {
            val outputSize = rb.available()
            if (outputSize > 0) {
                if (buffer.capacity() < outputSize * channelCount * 2) {
                    buffer = ByteBuffer.allocateDirect(outputSize * channelCount * 2)
                        .order(ByteOrder.nativeOrder())
                    shortBuffer = buffer.asShortBuffer()
                } else {
                    buffer.clear()
                    shortBuffer.clear()
                }
                val retrieved = rb.retrieve(shortBuffer, channelCount)
                outputBytes += retrieved.toLong() * channelCount * 2
                buffer.limit(retrieved * channelCount * 2)
                outputBuffer = buffer
            }
        }
        val outputBuffer = outputBuffer
        this.outputBuffer = AudioProcessor.EMPTY_BUFFER
        return outputBuffer
    }

    override fun isEnded(): Boolean {
        Log.e("inputeEnded", inputEnded.toString())
        Log.e("rb", rb.toString())
        val samplesRequired= rb?.samplesRequired

        Log.e("rb sample required", samplesRequired.toString())

       // return inputEnded && (rb == null || samplesRequired == 0)
        return inputEnded
    }

    override fun flush() {
        val isAct=isActive();
        Log.e("IsActive", isAct.toString())

        if (isAct) {
            Log.e("pendingSonicRecreation", pendingSonicRecreation.toString()  )
            inputAudioFormat = pendingInputAudioFormat
            outputAudioFormat = pendingOutputAudioFormat
            if (pendingSonicRecreation) {

                rb = RubberBandStretcher(
                    inputAudioFormat.sampleRate,
                    inputAudioFormat.channelCount,
                    RubberBandStretcher.OptionProcessRealTime.or(RubberBandStretcher.OptionEngineFiner).or(RubberBandStretcher.OptionWindowShort).or(RubberBandStretcher.OptionFormantPreserved).or(RubberBandStretcher.OptionPitchHighConsistency),
                    speed.toDouble(),
                    pitch.toDouble()
                )

            } else if (rb != null) {

                rb!!.reset()
            }
        }
        outputBuffer = AudioProcessor.EMPTY_BUFFER
        inputBytes = 0
        outputBytes = 0
        inputEnded = false
    }

    override fun reset() {
        speed = 1f
        pitch = 1f
        pendingInputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        pendingOutputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        inputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        outputAudioFormat = AudioProcessor.AudioFormat.NOT_SET
        buffer = AudioProcessor.EMPTY_BUFFER
        shortBuffer = buffer.asShortBuffer()
        outputBuffer = AudioProcessor.EMPTY_BUFFER
        pendingOutputSampleRate = SAMPLE_RATE_NO_CHANGE
        pendingSonicRecreation = false
        rb = null
        inputBytes = 0
        outputBytes = 0
        inputEnded = false
    }
}

Я пробовал изменить размер буфера.