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

eth/filters: subscribe pending logs

Browse source 
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
jsvisa 2023-06-27 01:04:09 +08:00
parent 223f05ff76
commit 7f3b72fe10
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
eth/filters/api.go
View file

@ -284,12 +284,12 @@ func (api *FilterAPI) logs(ctx context.Context, notifier notifier, rpcSub *rpc.S
to = rpc.BlockNumber(crit.ToBlock.Int64()) to = rpc.BlockNumber(crit.ToBlock.Int64())
} }
if to != rpc.LatestBlockNumber { if to != rpc.LatestBlockNumber && to != rpc.PendingBlockNumber {
return errInvalidToBlock return errInvalidToBlock
} }
// do live filter only // do live filter only
if from == rpc.LatestBlockNumber { if from == rpc.LatestBlockNumber || from == rpc.PendingBlockNumber {
return api.liveLogs(ctx, notifier, rpcSub, crit) return api.liveLogs(ctx, notifier, rpcSub, crit)
} }