mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-07-23 13:16:42 +00:00
fix minor bug
Signed-off-by: jsvisa <delweng@gmail.com>
This commit is contained in:
parent
554662b3d7
commit
c7bfb244df
1 changed files with 4 additions and 0 deletions
|
|
@ -327,6 +327,10 @@ func (es *EventSystem) SubscribeLogs(crit ethereum.FilterQuery, logs chan []*typ
|
||||||
if from >= 0 && to >= 0 && to >= from {
|
if from >= 0 && to >= 0 && to >= from {
|
||||||
return es.subscribeLogs(crit, logs), nil
|
return es.subscribeLogs(crit, logs), nil
|
||||||
}
|
}
|
||||||
|
// interested in mined logs from a specific block number, new logs and pending logs
|
||||||
|
if (from == rpc.LatestBlockNumber || from >= 0) && to == rpc.PendingBlockNumber {
|
||||||
|
return es.subscribeMinedPendingLogs(crit, logs), nil
|
||||||
|
}
|
||||||
// interested in logs from a specific block number to new mined blocks
|
// interested in logs from a specific block number to new mined blocks
|
||||||
if from >= 0 && to == rpc.LatestBlockNumber {
|
if from >= 0 && to == rpc.LatestBlockNumber {
|
||||||
return es.subscribeLogs(crit, logs), nil
|
return es.subscribeLogs(crit, logs), nil
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue