From 9ba4611433581f776863aca9d07ffcb193712bcc Mon Sep 17 00:00:00 2001 From: David Zhou Date: Tue, 13 May 2025 10:06:37 -0400 Subject: [PATCH] FIX: Local buffers --- eth/tracers/firehose_concurrency_test.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/eth/tracers/firehose_concurrency_test.go b/eth/tracers/firehose_concurrency_test.go index d69291e858..902a62b04d 100644 --- a/eth/tracers/firehose_concurrency_test.go +++ b/eth/tracers/firehose_concurrency_test.go @@ -15,6 +15,7 @@ import ( func TestFirehose_BlockPrintsToFirehose_SingleBlock(t *testing.T) { f := NewFirehose(&FirehoseConfig{ + ConcurrentBlockFlushing: true, ApplyBackwardCompatibility: ptr(false), private: &privateFirehoseConfig{ FlushToTestBuffer: true, @@ -61,10 +62,11 @@ func TestFirehose_BlockPrintsToFirehose_SingleBlock(t *testing.T) { func TestFirehose_BlocksPrintToFirehose_MultipleBlocksInOrder(t *testing.T) { - const blockCount = 100 + const blockCount = 10 const baseBlockNum = 1000 f := NewFirehose(&FirehoseConfig{ + ConcurrentBlockFlushing: true, ApplyBackwardCompatibility: ptr(false), private: &privateFirehoseConfig{ FlushToTestBuffer: true,