Add backpressure operator

Tinder · Sep 27, 2018 · 45de94a · 45de94a
1 parent 936eb8d
commit 45de94a
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
         }