Merge pull request #26 from Tinder/Add-backpressure-operator

Add backpressure operator
Tinder · Sep 27, 2018 · 4e65cc3 · 4e65cc3
2 parents 936eb8d + 45de94a
commit 4e65cc3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/scarlet/src/main/java/com/tinder/scarlet/internal/connection/Connection.kt b/scarlet/src/main/java/com/tinder/scarlet/internal/connection/Connection.kt
@@ -177,6 +177,7 @@ internal class Connection(
         private fun scheduleRetry(duration: Long): Disposable {
             val retryTimerScheduler = RetryTimerSubscriber(this)
             Flowable.timer(duration, TimeUnit.MILLISECONDS, scheduler)
+                .onBackpressureBuffer()
                 .subscribe(retryTimerScheduler)
             return retryTimerScheduler
         }