diff options
Diffstat (limited to 'android/lib/ipc/src')
| -rw-r--r-- | android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt b/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt index dd73f3c156..efaa1b78f8 100644 --- a/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt +++ b/android/lib/ipc/src/main/kotlin/net/mullvad/mullvadvpn/lib/ipc/DispatchingHandler.kt @@ -15,7 +15,8 @@ class DispatchingHandler<T : Any>(looper: Looper, private val extractor: (Messag private val handlers = HashMap<KClass<out T>, (T) -> Unit>() private val lock = ReentrantReadWriteLock() - private val _parsedMessages = MutableSharedFlow<T>(extraBufferCapacity = 1) + private val _parsedMessages = + MutableSharedFlow<T>(extraBufferCapacity = MESSAGES_BUFFER_CAPACITY) val parsedMessages = _parsedMessages.asSharedFlow() @Deprecated("Use parsedMessages instead.") @@ -45,4 +46,8 @@ class DispatchingHandler<T : Any>(looper: Looper, private val extractor: (Messag removeCallbacksAndMessages(null) } + + companion object { + private const val MESSAGES_BUFFER_CAPACITY = 10 + } } |