From be95b689647c9ec8807e141b99e0d5237513a822 Mon Sep 17 00:00:00 2001 From: Termina1 Date: Fri, 29 Aug 2025 13:51:26 +0300 Subject: [PATCH] increase backpressure buffer for subscription syncs --- .../dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt b/src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/SharedLogsProducer.kt index 64b4b7df..6f51c68b 100644 --- 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() + val logsSink = Sinks.many().multicast().onBackpressureBuffer(4096) logsSinks[matcherKey] = logsSink val sharedStream = produceLogs.produce(connectBlockUpdates.connect(matcher))