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
index f5cde9f7..4a51ec72 100644
--- 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
         }