increase backpressure buffer for subscription syncs

2025-08-29 13:51:26 +03:00
parent 0ec7e4fd70
commit be95b68964
1 changed files with 1 additions and 1 deletions
--- a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt
+++ b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt
@@ -80,7 +80,7 @@ class SharedLogsProducer(
    private fun startSharedStream(matcher: Selector.Matcher) {
        val matcherKey = matcher.describeInternal()

-        val logsSink = Sinks.many().multicast().onBackpressureBuffer<LogMessage>()
+        val logsSink = Sinks.many().multicast().onBackpressureBuffer<LogMessage>(4096)
        logsSinks[matcherKey] = logsSink

        val sharedStream = produceLogs.produce(connectBlockUpdates.connect(matcher))