add buffer

crypto-org-chain · Nov 9, 2023 · 85680ef · 85680ef
1 parent 3905524
commit 85680ef
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/rpc/namespaces/ethereum/eth/filters/filter_system.go b/rpc/namespaces/ethereum/eth/filters/filter_system.go
@@ -41,7 +41,10 @@ import (
 	evmtypes "github.com/evmos/ethermint/x/evm/types"
 )
 
-const subscriberName = "eth_filter"
+const (
+	subscriberName     = "eth_filter"
+	subscribBufferSize = 2048
+)
 
 var (
 	txEvents  = tmtypes.QueryForEvent(tmtypes.EventTx).String()
@@ -134,11 +137,11 @@ func (es *EventSystem) subscribe(sub *Subscription) (*Subscription, pubsub.Unsub
 
 	switch sub.typ {
 	case filters.LogsSubscription:
-		chEvents, err = es.evtClient.Subscribe(ctx, subscriberName, sub.event)
+		chEvents, err = es.evtClient.Subscribe(ctx, subscriberName, sub.event, subscribBufferSize)
 	case filters.BlocksSubscription:
-		chEvents, err = es.evtClient.Subscribe(ctx, subscriberName, sub.event)
+		chEvents, err = es.evtClient.Subscribe(ctx, subscriberName, sub.event, subscribBufferSize)
 	case filters.PendingTransactionsSubscription:
-		chEvents, err = es.evtClient.Subscribe(ctx, subscriberName, sub.event)
+		chEvents, err = es.evtClient.Subscribe(ctx, subscriberName, sub.event, subscribBufferSize)
 	default:
 		err = fmt.Errorf("invalid filter subscription type %d", sub.typ)
 	}