Skip to content

Commit

Permalink
Fix account history events being lost because of buffer overflow
Browse files Browse the repository at this point in the history
  • Loading branch information
Pururun committed Nov 21, 2023
1 parent 57085fc commit e238ae1
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ 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 = 10)
val parsedMessages = _parsedMessages.asSharedFlow()

@Deprecated("Use parsedMessages instead.")
Expand Down

0 comments on commit e238ae1

Please sign in to comment.