forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-23 13:16:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

handle unwell sub on success

Browse source
This commit is contained in:
aodhgan 2025-10-13 13:16:50 -07:00
parent 409eea4063
commit eed426c36f
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
internal/ethapi/api.go
View file

@ -55,6 +55,7 @@ import (
const estimateGasErrorRatio = 0.015 const estimateGasErrorRatio = 0.015
var errBlobTxNotSupported = errors.New("signing blob transactions not supported") var errBlobTxNotSupported = errors.New("signing blob transactions not supported")
var errSubClosed = errors.New("chain subscription closed")
// EthereumAPI provides an API to access Ethereum related information. // EthereumAPI provides an API to access Ethereum related information.
type EthereumAPI struct { type EthereumAPI struct {
@ -1710,11 +1711,14 @@ func (api *TransactionAPI) SendRawTransactionSync(ctx context.Context, input hex
case err, ok := <-subErrCh: case err, ok := <-subErrCh:
if !ok { if !ok {
return nil, errors.New("chain subscription closed") return nil, errSubClosed
} }
return nil, err return nil, err
case ev := <-ch: case ev, ok := <-ch:
if !ok {
return nil, errSubClosed
}
rs := ev.Receipts rs := ev.Receipts
txs := ev.Transactions txs := ev.Transactions
if len(rs) == 0 || len(rs) != len(txs) { if len(rs) == 0 || len(rs) != len(txs) {