diff --git a/eth/filters/api.go b/eth/filters/api.go index 31252dcf04..1f82f981d7 100644 --- a/eth/filters/api.go +++ b/eth/filters/api.go @@ -284,12 +284,12 @@ func (api *FilterAPI) logs(ctx context.Context, notifier notifier, rpcSub *rpc.S to = rpc.BlockNumber(crit.ToBlock.Int64()) } - if to != rpc.LatestBlockNumber { + if to != rpc.LatestBlockNumber && to != rpc.PendingBlockNumber { return errInvalidToBlock } // do live filter only - if from == rpc.LatestBlockNumber { + if from == rpc.LatestBlockNumber || from == rpc.PendingBlockNumber { return api.liveLogs(ctx, notifier, rpcSub, crit) }