Merge pull request #47 from rikitikitaco/backpressure

add onBackpressureBuffer to Connection.kt
Tinder · Jan 17, 2019 · 5457f82 · 5457f82
2 parents d2d0909 + 0b12586
commit 5457f82
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...-okhttp/src/main/java/com/tinder/scarlet/websocket/okhttp/OkHttpWebSocketEventObserver.kt b/...-okhttp/src/main/java/com/tinder/scarlet/websocket/okhttp/OkHttpWebSocketEventObserver.kt
@@ -16,7 +16,7 @@ import okio.ByteString
 internal class OkHttpWebSocketEventObserver : WebSocketListener() {
     private val processor = PublishProcessor.create<WebSocket.Event>().toSerialized()
 
-    fun observe(): Flowable<WebSocket.Event> = processor
+    fun observe(): Flowable<WebSocket.Event> = processor.onBackpressureBuffer()
 
     fun terminate() = processor.onComplete()
 

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
@@ -166,7 +166,7 @@ internal class Connection(
             }
         }
 
-        fun observeEvent(): Flowable<Event> = eventProcessor
+        fun observeEvent(): Flowable<Event> = eventProcessor.onBackpressureBuffer()
 
         fun subscribe() {
             lifecycle.subscribe(lifecycleStateSubscriber)