Fix tests

drpcorg · Nov 7, 2023 · 8fbf6d2 · 8fbf6d2
1 parent 3bc9447
commit 8fbf6d2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/groovy/io/emeraldpay/dshackle/test/MultistreamHolderMock.groovy b/src/test/groovy/io/emeraldpay/dshackle/test/MultistreamHolderMock.groovy
@@ -47,7 +47,7 @@ class MultistreamHolderMock implements MultistreamHolder {
                     upstreams[chain] = up
                 } else if (up instanceof GenericUpstream) {
                     upstreams[chain] = new GenericMultistream(
-                            chain, Schedulers.boundedElastic(), null, new ArrayList<Upstream>(), Caches.default(),
+                            chain, Schedulers.immediate(), null, new ArrayList<Upstream>(), Caches.default(),
                             Schedulers.boundedElastic(),
                             EthereumChainSpecific.INSTANCE.makeCachingReaderBuilder(TestingCommons.tracerMock()),
                             EthereumChainSpecific.INSTANCE.&localReaderBuilder,
@@ -101,7 +101,7 @@ class MultistreamHolderMock implements MultistreamHolder {
         Head customHead = null
 
         EthereumMultistreamMock(@NotNull Chain chain, @NotNull List<GenericUpstream> upstreams, @NotNull Caches caches) {
-            super(chain, Schedulers.boundedElastic(), null, upstreams, caches, Schedulers.boundedElastic(),
+            super(chain, Schedulers.immediate(), null, upstreams, caches, Schedulers.boundedElastic(),
                     EthereumChainSpecific.INSTANCE.makeCachingReaderBuilder(new BraveTracer(null, null, null)),
                     EthereumChainSpecific.INSTANCE.&localReaderBuilder,
                     EthereumChainSpecific.INSTANCE.subscriptionBuilder(Schedulers.boundedElastic()))