BehaviorProcessor

Elyniss · Aug 2, 2022 · 934d975 · 934d975
1 parent 1a62d90
commit 934d975
Showing 1 changed file 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
@@ -8,13 +8,13 @@ import com.tinder.scarlet.Message
 import com.tinder.scarlet.ShutdownReason
 import com.tinder.scarlet.WebSocket
 import io.reactivex.Flowable
-import io.reactivex.processors.PublishProcessor
+import io.reactivex.processors.BehaviorProcessor
 import okhttp3.Response
 import okhttp3.WebSocketListener
 import okio.ByteString
 
 internal class OkHttpWebSocketEventObserver : WebSocketListener() {
-    private val processor = PublishProcessor.create<WebSocket.Event>().toSerialized()
+    private val processor = BehaviorProcessor.create<WebSocket.Event>().toSerialized()
 
     fun observe(): Flowable<WebSocket.Event> = processor.onBackpressureBuffer()