diff options
| author | Jonatan Rhodin <jonatan.rhodin@mullvad.net> | 2023-11-22 15:03:33 +0100 |
|---|---|---|
| committer | Jonatan Rhodin <jonatan.rhodin@mullvad.net> | 2023-11-22 15:03:33 +0100 |
| commit | 507e5c9b482b5416e1257c612505495c9ae84797 (patch) | |
| tree | f9540ca0613718cb8bf1dacaf937b1f08720f8fe /android | |
| parent | 5d67b95e68b1df320a10d3733a57b82661d08c97 (diff) | |
| parent | c1c2cba7f6b916c94f8304e3d82f343f64ce25c0 (diff) | |
| download | mullvadvpn-507e5c9b482b5416e1257c612505495c9ae84797.tar.xz mullvadvpn-507e5c9b482b5416e1257c612505495c9ae84797.zip | |
Merge branch 'inconsistent-behavior-of-the-account-history-droid-519'
Diffstat (limited to 'android')
| -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 + } } |
