From a839372d9f9cd3fdf80c1a0661202bb7adb05933 Mon Sep 17 00:00:00 2001
From: Rani Sargees <cheeze.sprinkels+official_git@gmail.com>
Date: Sun, 12 Jul 2020 15:13:17 -0400
Subject: [PATCH] fix batch add log

(cherry picked from commit 629bca4100243d61cf07bbb0f47f6a1ed84031cb)
---
 app/src/main/java/exh/ui/batchadd/BatchAddController.kt | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/app/src/main/java/exh/ui/batchadd/BatchAddController.kt b/app/src/main/java/exh/ui/batchadd/BatchAddController.kt
index 88604522f..fae01e6e2 100755
--- a/app/src/main/java/exh/ui/batchadd/BatchAddController.kt
+++ b/app/src/main/java/exh/ui/batchadd/BatchAddController.kt
@@ -49,12 +49,14 @@ class BatchAddController : NucleusController<EhFragmentBatchAddBinding, BatchAdd
             val progressSubscriptions = CompositeSubscription()
 
             presenter.currentlyAddingRelay
+                .onBackpressureBuffer()
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribeUntilDestroy {
                     progressSubscriptions.clear()
                     if (it == BatchAddPresenter.STATE_INPUT_TO_PROGRESS) {
                         showProgress(this)
                         progressSubscriptions += presenter.progressRelay
+                            .onBackpressureBuffer()
                             .observeOn(AndroidSchedulers.mainThread())
                             .combineLatest(presenter.progressTotalRelay) { progress, total ->
                                 // Show hide dismiss button
@@ -71,18 +73,21 @@ class BatchAddController : NucleusController<EhFragmentBatchAddBinding, BatchAdd
                             }
 
                         progressSubscriptions += presenter.progressTotalRelay
+                            .onBackpressureBuffer()
                             .observeOn(AndroidSchedulers.mainThread())
                             .subscribeUntilDestroy {
                                 binding.progressBar.max = it
                             }
 
                         progressSubscriptions += presenter.progressRelay
+                            .onBackpressureBuffer()
                             .observeOn(AndroidSchedulers.mainThread())
                             .subscribeUntilDestroy {
                                 binding.progressBar.progress = it
                             }
 
                         presenter.eventRelay
+                            ?.onBackpressureBuffer()
                             ?.observeOn(AndroidSchedulers.mainThread())
                             ?.subscribeUntilDestroy {
                                 binding.progressLog.append("$it\n")