unbuffer chan

Darioush Jalali · Darioush Jalali · commit b08c9e04630b · 2024-08-28T10:28:13.000-07:00
diff --git a/core/txindexer.go b/core/txindexer.go
@@ -127,7 +127,7 @@ func (indexer *txIndexer) loop(chain *BlockChain) {
 		lastHead uint64                              // The latest announced chain head (whose tx indexes are assumed created)
 		lastTail = rawdb.ReadTxIndexTail(indexer.db) // The oldest indexed block, nil means nothing indexed
 
-		headCh = make(chan ChainEvent, 1)
+		headCh = make(chan ChainEvent)
 		sub    = chain.SubscribeChainAcceptedEvent(headCh)
 	)
 	if sub == nil {

Original file line number	Diff line number	Diff line change
`@@ -127,7 +127,7 @@ func (indexer txIndexer) loop(chain BlockChain) {`
`127`	`127`	`lastHead uint64 // The latest announced chain head (whose tx indexes are assumed created)`
`128`	`128`	`lastTail = rawdb.ReadTxIndexTail(indexer.db) // The oldest indexed block, nil means nothing indexed`
`129`	`129`
`130`		`- headCh = make(chan ChainEvent, 1)`
	`130`	`+ headCh = make(chan ChainEvent)`
`131`	`131`	`sub = chain.SubscribeChainAcceptedEvent(headCh)`
`132`	`132`	`)`
`133`	`133`	`if sub == nil {`